-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(janitor): add otlp logger for janitor (#1686)
<!--- Provide a general summary of your changes in the Title above --> ## Description <!--- Describe your changes in detail --> ## Related Issue(s) - #1616 ## Verification - [ ] **Your** code builds clean without any errors or warnings - [ ] Manual testing done (required) - [ ] Relevant automated test added (if you find this hard, leave it and we'll help out) ## Documentation - [ ] Documentation is updated (either in `docs`-directory, Altinnpedia or a separate linked PR in [altinn-studio-docs.](https://github.com/Altinn/altinn-studio-docs), if applicable)
- Loading branch information
Showing
3 changed files
with
167 additions
and
8 deletions.
There are no files selected for viewing
153 changes: 153 additions & 0 deletions
153
src/Digdir.Domain.Dialogporten.Janitor/Common/Extensions/OpenTelemetryExtensions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,153 @@ | ||
| using Azure.Monitor.OpenTelemetry.Exporter; | ||
| using Npgsql; | ||
| using OpenTelemetry.Exporter; | ||
| using OpenTelemetry.Metrics; | ||
| using OpenTelemetry.Resources; | ||
| using OpenTelemetry.Trace; | ||
| using System.Diagnostics; | ||
| using System.Globalization; | ||
| using Serilog; | ||
| using Serilog.Configuration; | ||
| using Serilog.Sinks.OpenTelemetry; | ||
| using Microsoft.Extensions.DependencyInjection; | ||
| using Microsoft.Extensions.Configuration; | ||
| using Microsoft.Extensions.Hosting; | ||
|
|
||
| namespace Digdir.Domain.Dialogporten.Janitor.Common.Extensions; | ||
|
|
||
| internal static class OpenTelemetryExtensions | ||
| { | ||
| private const string OtelExporterOtlpEndpoint = "OTEL_EXPORTER_OTLP_ENDPOINT"; | ||
| private const string OtelExporterOtlpProtocol = "OTEL_EXPORTER_OTLP_PROTOCOL"; | ||
|
|
||
| public static IServiceCollection AddDialogportenTelemetry( | ||
| this IServiceCollection services, | ||
| IConfiguration configuration, | ||
| IHostEnvironment environment) | ||
| { | ||
| if (!Uri.IsWellFormedUriString(configuration[OtelExporterOtlpEndpoint], UriKind.Absolute)) | ||
| return services; | ||
|
|
||
| var otlpProtocol = configuration[OtelExporterOtlpProtocol]?.ToLowerInvariant() switch | ||
| { | ||
| "grpc" => OtlpExportProtocol.Grpc, | ||
| "http/protobuf" => OtlpExportProtocol.HttpProtobuf, | ||
| _ => throw new ArgumentException($"Unsupported protocol: {configuration[OtelExporterOtlpProtocol]}") | ||
| }; | ||
|
|
||
| var endpoint = new Uri(configuration[OtelExporterOtlpEndpoint]!); | ||
|
|
||
| return services.AddOpenTelemetry() | ||
| .ConfigureResource(resource => | ||
| { | ||
| resource.AddService( | ||
| serviceName: configuration["OTEL_SERVICE_NAME"] ?? environment.ApplicationName); | ||
| }) | ||
| .WithTracing(tracing => | ||
| { | ||
| if (environment.IsDevelopment()) | ||
| { | ||
| tracing.SetSampler(new AlwaysOnSampler()); | ||
| } | ||
|
|
||
| tracing | ||
| .AddHttpClientInstrumentation(o => | ||
| { | ||
| o.RecordException = true; | ||
| o.FilterHttpRequestMessage = _ => | ||
| { | ||
| var parentActivity = Activity.Current?.Parent; | ||
| if (parentActivity != null && parentActivity.Source.Name.Equals("Azure.Core.Http", StringComparison.Ordinal)) | ||
| { | ||
| return false; | ||
| } | ||
| return true; | ||
| }; | ||
| }) | ||
| .AddEntityFrameworkCoreInstrumentation() | ||
| .AddNpgsql() | ||
| .AddFusionCacheInstrumentation() | ||
| .AddOtlpExporter(options => | ||
| { | ||
| options.Endpoint = new Uri(endpoint, "/v1/traces"); | ||
| options.Protocol = otlpProtocol; | ||
| }); | ||
| }) | ||
| .WithMetrics(metrics => | ||
| { | ||
| metrics.AddRuntimeInstrumentation() | ||
| .AddHttpClientInstrumentation(); | ||
|
|
||
| var appInsightsConnectionString = configuration["APPLICATIONINSIGHTS_CONNECTION_STRING"]; | ||
| if (!string.IsNullOrEmpty(appInsightsConnectionString)) | ||
| { | ||
| metrics.AddAzureMonitorMetricExporter(options => | ||
| { | ||
| options.ConnectionString = appInsightsConnectionString; | ||
| }); | ||
| } | ||
| else | ||
| { | ||
| metrics.AddOtlpExporter(options => | ||
| { | ||
| options.Endpoint = new Uri(endpoint, "/v1/metrics"); | ||
| options.Protocol = otlpProtocol; | ||
| }); | ||
| } | ||
| }) | ||
| .Services; | ||
| } | ||
|
|
||
| public static LoggerConfiguration OpenTelemetryOrConsole(this LoggerSinkConfiguration writeTo, HostBuilderContext context) | ||
| { | ||
| var otelEndpoint = context.Configuration[OtelExporterOtlpEndpoint]; | ||
| var otelProtocol = context.Configuration[OtelExporterOtlpProtocol]; | ||
|
|
||
| return otelEndpoint switch | ||
| { | ||
| null => | ||
| writeTo.Console(formatProvider: CultureInfo.InvariantCulture), | ||
| not null when Uri.IsWellFormedUriString(otelEndpoint, UriKind.Absolute) => | ||
| writeTo.OpenTelemetry(ConfigureOtlpSink(otelEndpoint, ParseOtlpProtocol(otelProtocol))), | ||
| _ => throw new InvalidOperationException($"Invalid otel endpoint: {otelEndpoint}") | ||
| }; | ||
| } | ||
|
|
||
| public static LoggerConfiguration TryWriteToOpenTelemetry(this LoggerConfiguration config) | ||
| { | ||
| var otelEndpoint = Environment.GetEnvironmentVariable(OtelExporterOtlpEndpoint); | ||
| var otelProtocol = Environment.GetEnvironmentVariable(OtelExporterOtlpProtocol); | ||
|
|
||
| if (otelEndpoint is null || !Uri.IsWellFormedUriString(otelEndpoint, UriKind.Absolute)) | ||
| { | ||
| return config; | ||
| } | ||
|
|
||
| try | ||
| { | ||
| var protocol = ParseOtlpProtocol(otelProtocol); | ||
| return config.WriteTo.OpenTelemetry(ConfigureOtlpSink(otelEndpoint, protocol)); | ||
| } | ||
| catch (ArgumentException) | ||
| { | ||
| return config; | ||
| } | ||
| } | ||
|
|
||
| private static OtlpProtocol ParseOtlpProtocol(string? protocol) | ||
| { | ||
| return protocol?.ToLowerInvariant() switch | ||
| { | ||
| "grpc" => OtlpProtocol.Grpc, | ||
| "http/protobuf" => OtlpProtocol.HttpProtobuf, | ||
| _ => throw new ArgumentException($"Unsupported OTLP protocol: {protocol}") | ||
| }; | ||
| } | ||
|
|
||
| private static Action<OpenTelemetrySinkOptions> ConfigureOtlpSink(string endpoint, OtlpProtocol protocol) => | ||
| options => | ||
| { | ||
| options.Endpoint = endpoint; | ||
| options.Protocol = protocol; | ||
| }; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters