@@ -13,6 +13,7 @@ namespace Serilog.Sinks.Aliyun.Batched;
13
13
public sealed class BatchedAliyunSink : IBatchedLogEventSink
14
14
{
15
15
private readonly string _logStore ;
16
+ private readonly bool _logMessageTemplate ;
16
17
private readonly string _topic ;
17
18
private readonly HttpLogServiceClient _client ;
18
19
private readonly string _source ;
@@ -24,9 +25,11 @@ public BatchedAliyunSink(string accessKeyId,
24
25
string logStore ,
25
26
string ? topic = null ,
26
27
string ? source = null ,
28
+ bool logMessageTemplate = true ,
27
29
int requestTimeout = 1000 )
28
30
{
29
31
_logStore = logStore ;
32
+ _logMessageTemplate = logMessageTemplate ;
30
33
_topic = topic ?? string . Empty ;
31
34
_source = source ?? string . Empty ;
32
35
_client = LogServiceClientBuilders . HttpBuilder
@@ -49,7 +52,10 @@ public async Task EmitBatchAsync(IReadOnlyCollection<LogEvent> batch)
49
52
50
53
log . Contents . Add ( "@Level" , logEvent . Level . ToString ( ) ) ;
51
54
log . Contents . Add ( "@Message" , logEvent . RenderMessage ( ) ) ;
52
- log . Contents . Add ( "@MessageTemplate" , logEvent . MessageTemplate . Text ) ;
55
+ if ( _logMessageTemplate )
56
+ {
57
+ log . Contents . Add ( "@MessageTemplate" , logEvent . MessageTemplate . Text ) ;
58
+ }
53
59
54
60
if ( logEvent . Exception != null )
55
61
{
0 commit comments