Trace .NET Lambda functions

1dotnet add package Dynatrace.OpenTelemetry.Instrumentation.AwsLambda

1using System.Threading.Tasks;
2using Amazon.Lambda.Core;
3using Dynatrace.OpenTelemetry;
4using Dynatrace.OpenTelemetry.Instrumentation.AwsLambda;
5using OpenTelemetry;
6using OpenTelemetry.Instrumentation.AWSLambda;
7using OpenTelemetry.Trace;
8
9[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]
10
11namespace Examples.AwsFunctionApp
12{
13    public class Function
14    {
15        private static readonly TracerProvider TracerProvider;
16
17        static Function()
18        {
19            DynatraceSetup.InitializeLogging();
20            TracerProvider = Sdk.CreateTracerProviderBuilder()
21                .AddDynatrace()
22                // Configures AWS Lambda invocations tracing
23                .AddAWSLambdaConfigurations(c => c.DisableAwsXRayContextExtraction = true)
24                // Instrumentation for creation of span (Activity) representing AWS SDK call.
25                // Can be omitted if there are no outgoing AWS SDK calls to other AWS Lambdas and/or calls to AWS services like DynamoDB and SQS.
26                .AddAWSInstrumentation(c => c.SuppressDownstreamInstrumentation = true)
27                // Adds injection of Dynatrace-specific context information in certain SDK calls (e.g. Lambda Invoke).
28                // Can be omitted if there are no outgoing calls to other Lambdas via the AWS Lambda SDK.
29                .AddDynatraceAwsSdkInjection()
30                .Build();
31        }
32    }
33}

1using System.Threading.Tasks;
2using Amazon.Lambda.Core;
3using Dynatrace.OpenTelemetry;
4using Dynatrace.OpenTelemetry.Instrumentation.AwsLambda;
5using OpenTelemetry;
6using OpenTelemetry.Instrumentation.AWSLambda;
7using OpenTelemetry.Trace;
8
9[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]
10
11namespace Examples.AwsFunctionApp
12{
13    public class Function
14    {
15        private static readonly TracerProvider TracerProvider;
16
17        // Use initialization code from the "Initialization" section of the docs
18
19        public Task FunctionHandlerAsync(object input, ILambdaContext context)
20        {
21            var propagationContext = AwsLambdaHelpers.ExtractPropagationContext(context);
22            return AWSLambdaWrapper.TraceAsync(TracerProvider, FunctionHandlerInternalAsync, input, context, propagationContext.ActivityContext);
23        }
24
25        private Task FunctionHandlerInternalAsync(object input, ILambdaContext context)
26        {
27            // This is just an example of function handler and should be replaced by actual code.
28
29            return Task.CompletedTask;
30        }
31    }
32}

1using Amazon.Lambda.APIGatewayEvents;
2using Amazon.Lambda.Core;
3using Dynatrace.OpenTelemetry;
4using Dynatrace.OpenTelemetry.Instrumentation.AwsLambda;
5using OpenTelemetry;
6using OpenTelemetry.Instrumentation.AWSLambda;
7using OpenTelemetry.Trace;
8
9[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]
10
11namespace Examples.AwsFunctionApp
12{
13    public class Function
14    {
15        private static readonly TracerProvider TracerProvider;
16
17        // Use initialization code from the "Initialization" section of the docs
18
19        public APIGatewayHttpApiV2ProxyResponse FunctionHandler(APIGatewayHttpApiV2ProxyRequest request, ILambdaContext context)
20        {
21            return AWSLambdaWrapper.Trace(TracerProvider, FunctionHandlerInternal, request, context);
22        }
23
24        private APIGatewayHttpApiV2ProxyResponse FunctionHandlerInternal(APIGatewayHttpApiV2ProxyRequest request, ILambdaContext context)
25        {
26            // This is just an example of function handler and should be replaced by actual code.
27
28            return new APIGatewayHttpApiV2ProxyResponse
29            {
30                StatusCode = 200,
31                Body = "Example function result",
32            };
33        }
34    }
35}

1using System;
2using System.Collections.Generic;
3using System.Diagnostics;
4using System.Reflection;
5using Amazon.Lambda.APIGatewayEvents;
6using Amazon.Lambda.Core;
7using Dynatrace.OpenTelemetry;
8using Dynatrace.OpenTelemetry.Instrumentation.AwsLambda;
9using OpenTelemetry;
10using OpenTelemetry.Context.Propagation;
11using OpenTelemetry.Trace;
12
13[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]
14
15namespace Examples.AwsFunctionApp
16{
17    public class Function
18    {
19        private static readonly TracerProvider TracerProvider;
20        private static readonly ActivitySource ActivitySource;
21
22        static Function()
23        {
24            DynatraceSetup.InitializeLogging();
25            var activitySourceName = Assembly.GetExecutingAssembly().GetName().Name;
26            ActivitySource = new ActivitySource(activitySourceName);
27            TracerProvider = Sdk.CreateTracerProviderBuilder()
28                .AddSource(activitySourceName)
29                .AddDynatrace()
30                .Build();
31        }
32
33        public static IEnumerable<KeyValuePair<string, object>> GetFunctionTags(ILambdaContext context, string trigger)
34        {
35            return new KeyValuePair<string, object>[]
36            {
37                new("faas.name", context.FunctionName),
38                new("faas.id", context.InvokedFunctionArn),
39                new("faas.trigger", trigger),
40                new("cloud.platform", "aws_lambda"),
41                new("cloud.provider", "aws"),
42                new("cloud.region", Environment.GetEnvironmentVariable("AWS_REGION")),
43            };
44        }
45
46        public APIGatewayProxyResponse FunctionHandler(APIGatewayHttpApiV2ProxyRequest apiGatewayProxyEvent, ILambdaContext context)
47        {
48            try
49            {
50                var parentContext = ExtractParentContext(apiGatewayProxyEvent, context);
51                using var activity = ActivitySource.StartActivity(ActivityKind.Server, parentContext, GetFunctionTags(context, "http"));
52                return new APIGatewayProxyResponse
53                {
54                    StatusCode = 200,
55                    Body = "Example function result",
56                };
57            }
58            catch (Exception ex)
59            {
60                context.Logger.LogLine($"Exception occurred while handling request: {ex.Message}");
61                throw;
62            }
63            finally
64            {
65                TracerProvider?.ForceFlush();
66            }
67        }
68
69        private static ActivityContext ExtractParentContext(APIGatewayHttpApiV2ProxyRequest apiGatewayProxyEvent, ILambdaContext context)
70        {
71            var propagationContext = AwsLambdaHelpers.ExtractPropagationContext(context);
72            if (propagationContext == default)
73            {
74                propagationContext = Propagators.DefaultTextMapPropagator.Extract(default, apiGatewayProxyEvent, HeaderValuesGetter);
75            }
76
77            return propagationContext.ActivityContext;
78        }
79
80        private static IEnumerable<string> HeaderValuesGetter(APIGatewayHttpApiV2ProxyRequest apiGatewayProxyEvent, string name) =>
81            (apiGatewayProxyEvent.Headers != null && apiGatewayProxyEvent.Headers.TryGetValue(name.ToLowerInvariant(), out var value)) ? new[] { value } : null;
82    }
83}

1using Amazon.Lambda.Core;
2using Amazon.Lambda.SQSEvents;
3using Dynatrace.OpenTelemetry;
4using OpenTelemetry;
5using OpenTelemetry.Instrumentation.AWSLambda;
6using OpenTelemetry.Trace;
7using System.Threading.Tasks;
8
9namespace Examples.AwsFunctionApp
10{
11    public class Function
12    {
13        private static readonly TracerProvider TracerProvider;
14
15        static Function()
16        {
17            // See "Set up tracing for AWS SDK calls" section above.
18        }
19
20        public Task Handler(SQSEvent sqsEvent, ILambdaContext context) =>
21            AWSLambdaWrapper.TraceAsync(tracerProvider, HandlerInternal, sqsEvent, context);
22
23        private Task HandlerInternal(SQSEvent sqsEvent, ILambdaContext context)
24        {
25            // This is just an example of async function handler and it should be replaced by actual code.
26
27            return Task.CompletedTask;
28        }
29    }
30}

1var tracerProvider = Sdk.CreateTracerProviderBuilder()
2        // Initialization code similar to previous examples...
3        .AddHttpClientInstrumentation(op =>
4        {
5            op.FilterHttpRequestMessage = req => Activity.Current?.Parent?.IsAllDataRequested ?? false;
6        })
7        .Build();