fixes #4583

fullstackhero · Oct 11, 2024 · 58af19c · 58af19c
1 parent 049d6ed
commit 58af19c
Showing 1 changed file with 31 additions and 0 deletions.
diff --git a/src/api/framework/Infrastructure/Logging/Serilog/Extensions.cs b/src/api/framework/Infrastructure/Logging/Serilog/Extensions.cs
@@ -12,8 +12,39 @@ public static WebApplicationBuilder ConfigureSerilog(this WebApplicationBuilder
         ArgumentNullException.ThrowIfNull(builder);
         builder.Host.UseSerilog((context, logger) =>
         {
+            logger.WriteTo.OpenTelemetry(options =>
+            {
+                try
+                {
+                    options.Endpoint = builder.Configuration["OTEL_EXPORTER_OTLP_ENDPOINT"];
+                    var headers = builder.Configuration["OTEL_EXPORTER_OTLP_HEADERS"]?.Split(',') ?? [];
+                    foreach (var header in headers)
+                    {
+                        var (key, value) = header.Split('=') switch
+                        {
+                        [string k, string v] => (k, v),
+                            var v => throw new Exception($"Invalid header format {v}")
+                        };
+
+                        options.Headers.Add(key, value);
+                    }
+                    options.ResourceAttributes.Add("service.name", "apiservice");
+                    //To remove the duplicate issue, we can use the below code to get the key and value from the configuration
+                    var (otelResourceAttribute, otelResourceAttributeValue) = builder.Configuration["OTEL_RESOURCE_ATTRIBUTES"]?.Split('=') switch
+                    {
+                    [string k, string v] => (k, v),
+                        _ => throw new Exception($"Invalid header format {builder.Configuration["OTEL_RESOURCE_ATTRIBUTES"]}")
+                    };
+                    options.ResourceAttributes.Add(otelResourceAttribute, otelResourceAttributeValue);
+                }
+                catch
+                {
+                    //ignore
+                }
+            });
             logger.ReadFrom.Configuration(context.Configuration);
             logger.Enrich.FromLogContext();
+            logger.Enrich.WithCorrelationId();
             logger
                 .MinimumLevel.Override("Microsoft", LogEventLevel.Warning)
                 .MinimumLevel.Override("Microsoft.Hosting.Lifetime", LogEventLevel.Information)