azure - Azure Functions 的 OpenTelemetry 和关联支持

Question

我有一个用 .net 6 编写的项目。我使用 Azure Function 将数据发送到服务总线和 MediatR。如何将开放遥测添加到我的 Azure 函数？

[Function("EBcktErroredFunction")]
  public Task EBcktErroredFunctionAsync([ServiceBusTrigger("e-bckt-errored", "bckts-creation-finalize")] EBcktErrored payload)
  {
    return _mediator.Send(
      new SyncBcktErroredToStoreCommand
      {
        SBcktId = payload.BcktId,
        EBcktId = payload.ExternalBcktId
      }
    );

不相关，但在二头肌文件中它看起来像这样；

resource eBcktErroredSubscription 'Microsoft.ServiceBus/namespaces/topics/subscriptions' = {
  name: '${serviceBusName}/e-bckt-errored/${appName}'
  properties: {
    autoDeleteOnIdle: ''
    deadLetteringOnMessageExpiration: 
    defaultMessageTimeToLive: ''
    enableBatchedOperations: true
    lockDuration: ''
  }
}

Answer 1

您可以在GitHub上找到完整的示例以及关于“Using OpenTelemetry Sdk with Azure Functions”的相应讨论。

最相关的代码(您应该查看完整的代码以供引用):

    public class Startup : FunctionsStartup
    {
        public override void Configure(IFunctionsHostBuilder builder)
        {
            // OpenTelemetry Resource to be associated with logs, metrics and traces
            var openTelemetryResourceBuilder = ResourceBuilder.CreateDefault().AddService("opentelemetry-service");

            // Enable Logging with OpenTelemetry
            builder.Services.AddLogging( (loggingBuilder) => 
                {
                    // Only Warning or above will be sent to Opentelemetry
                    loggingBuilder.AddFilter<OpenTelemetryLoggerProvider>("*", LogLevel.Warning);
                }
            );
            
            builder.Services.AddSingleton<ILoggerProvider, OpenTelemetryLoggerProvider>();
            builder.Services.Configure<OpenTelemetryLoggerOptions>( (openTelemetryLoggerOptions) =>
                {
                    openTelemetryLoggerOptions.SetResourceBuilder(openTelemetryResourceBuilder);
                    openTelemetryLoggerOptions.IncludeFormattedMessage = true;
                    openTelemetryLoggerOptions.AddConsoleExporter();
                }
            );

            // Enable Tracing with OpenTelemetry
            var openTelemetryTracerProvider = Sdk.CreateTracerProviderBuilder()
                .SetResourceBuilder(openTelemetryResourceBuilder)
                .SetSampler(new AlwaysOnSampler())
                .AddAspNetCoreInstrumentation()
                .AddConsoleExporter()
                .Build();
            builder.Services.AddSingleton(openTelemetryTracerProvider);

            // Enable Metrics with OpenTelemetry
            var openTelemetryMeterProvider = Sdk.CreateMeterProviderBuilder()
                .SetResourceBuilder(openTelemetryResourceBuilder)
                .AddAspNetCoreInstrumentation()
                .AddMeter(Function1.MyMeter.Name)
                .AddConsoleExporter(consoleOptions =>
                    {
                        consoleOptions.MetricReaderType = MetricReaderType.Periodic;
                        consoleOptions.AggregationTemporality = AggregationTemporality.Cumulative;
                        consoleOptions.PeriodicExportingMetricReaderOptions.ExportIntervalMilliseconds = 10000;
                    })
                .Build();
            builder.Services.AddSingleton(openTelemetryMeterProvider);

        [FunctionName("Function1")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            log.LogWarning("C# HTTP trigger function processed a request.");
            MyCounter.Add(1, new("name", "apple"), new("color", "red"));

            string name = req.Query["name"];

            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            name = name ?? data?.name;

            string responseMessage = string.IsNullOrEmpty(name)
                ? "This HTTP triggered function executed successfully. Pass a name in the query string or in the request body for a personalized response."
                : $"Hello, {name}. This HTTP triggered function executed successfully.";

            log.LogWarning("Name is {name}", name);
            Activity.Current?.SetTag("name", name);

            return new OkObjectResult(responseMessage);
        }