add support for Lambda EventSourceMapping attribute

Author: ezhang6811

src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsAttributeKeys.cs

@@ -48,6 +48,7 @@ internal sealed class AwsAttributeKeys
     internal static readonly string AttributeAWSDynamoTableName = "aws.table_name";
     internal static readonly string AttributeAWSSQSQueueUrl = "aws.queue_url";
 
+    internal static readonly string AttributeAWSLambdaResourceMappingId = "aws.lambda.resource_mapping.id";
     internal static readonly string AttributeAWSS3Bucket = "aws.s3.bucket";
     internal static readonly string AttributeAWSSecretsManagerSecretArn = "aws.secretsmanager.secret.arn";
     internal static readonly string AttributeAWSSNSTopicArn = "aws.sns.topic.arn";

src/AWS.Distro.OpenTelemetry.AutoInstrumentation/AwsMetricAttributeGenerator.cs

@@ -42,6 +42,7 @@ internal class AwsMetricAttributeGenerator : IMetricAttributeGenerator
     // Normalized remote service names for supported AWS services
     private static readonly string NormalizedDynamoDBServiceName = "AWS::DynamoDB";
     private static readonly string NormalizedKinesisServiceName = "AWS::Kinesis";
+    private static readonly string NormalizedLambdaServiceName = "AWS::Lambda";
     private static readonly string NormalizedS3ServiceName = "AWS::S3";
     private static readonly string NormalizedSecretsManagerServiceName = "AWS::SecretsManager";
     private static readonly string NormalizedSNSServiceName = "AWS::SNS";
@@ -361,6 +362,8 @@ private static string NormalizeRemoteServiceName(Activity span, string serviceNa
                 case "AmazonKinesis": // AWS SDK v1
                 case "Kinesis": // AWS SDK v2
                     return NormalizedKinesisServiceName;
+                case "Lambda":
+                    return NormalizedLambdaServiceName;
                 case "Amazon S3": // AWS SDK v1
                 case "S3": // AWS SDK v2
                     return NormalizedS3ServiceName;
@@ -407,6 +410,11 @@ private static void SetRemoteResourceTypeAndIdentifier(Activity span, ActivityTa
                 remoteResourceType = NormalizedKinesisServiceName + "::Stream";
                 remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSKinesisStreamName));
             }
+            else if (IsKeyPresent(span, AttributeAWSLambdaResourceMappingId))
+            {
+                remoteResourceType = NormalizedLambdaServiceName + "::EventSourceMapping";
+                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSLambdaResourceMappingId));
+            }
             else if (IsKeyPresent(span, AttributeAWSS3Bucket))
             {
                 remoteResourceType = NormalizedS3ServiceName + "::Bucket";

src/OpenTelemetry.Instrumentation.AWS/Implementation/AWSSemanticConventions.cs

@@ -15,6 +15,7 @@ internal static class AWSSemanticConventions
     public const string AttributeAWSSQSQueueName = "aws.sqs.queue_name";
     public const string AttributeAWSS3BucketName = "aws.s3.bucket";
     public const string AttributeAWSKinesisStreamName = "aws.kinesis.stream_name";
+    public const string AttributeAWSLambdaResourceMappingId = "aws.lambda.resource_mapping.id";
     public const string AttributeAWSSecretsManagerSecretArn = "aws.secretsmanager.secret.arn";
     public const string AttributeAWSSNSTopicArn = "aws.sns.topic.arn";
     public const string AttributeAWSStepFunctionsActivityArn = "aws.stepfunctions.activity.arn";

src/OpenTelemetry.Instrumentation.AWS/Implementation/AWSServiceHelper.cs

@@ -13,6 +13,7 @@ internal class AWSServiceHelper
         { AWSServiceType.SQSService, new List<string> { "QueueUrl", "QueueName" } },
         { AWSServiceType.S3Service, new List<string> { "BucketName" } },
         { AWSServiceType.KinesisService, new List<string> { "StreamName" } },
+        { AWSServiceType.LambdaService, new List<string> { "UUID" } },
         { AWSServiceType.SNSService, new List<string> { "TopicArn" } },
         { AWSServiceType.StepFunctionsService, new List<string> { "ActivityArn", "StateMachineArn" } },
         { AWSServiceType.BedrockRuntimeService, new List<string> { "ModelId" } },
@@ -39,6 +40,7 @@ internal class AWSServiceHelper
         { "ARN", AWSSemanticConventions.AttributeAWSSecretsManagerSecretArn },
         { "ActivityArn", AWSSemanticConventions.AttributeAWSStepFunctionsActivityArn },
         { "StateMachineArn", AWSSemanticConventions.AttributeAWSStepFunctionsStateMachineArn },
+        { "UUID", AWSSemanticConventions.AttributeAWSLambdaResourceMappingId },
         { "ModelId", AWSSemanticConventions.AttributeGenAiModelId },
         { "GuardrailId", AWSSemanticConventions.AttributeAWSBedrockGuardrailId },
         { "AgentId", AWSSemanticConventions.AttributeAWSBedrockAgentId },

src/OpenTelemetry.Instrumentation.AWS/Implementation/AWSServiceType.cs

@@ -10,6 +10,7 @@ internal class AWSServiceType
     internal const string SNSService = "SNS";
     internal const string S3Service = "S3";
     internal const string KinesisService = "Kinesis";
+    internal const string LambdaService = "Lambda";
     internal const string SecretsManagerService = "Secrets Manager";
     internal const string StepFunctionsService = "SFN";
     internal const string BedrockService = "Bedrock";
@@ -29,6 +30,9 @@ internal static bool IsSnsService(string service)
     internal static bool IsS3Service(string service)
         => S3Service.Equals(service, StringComparison.OrdinalIgnoreCase);
 
+    internal static bool IsLambdaService(string service)
+        => LambdaService.Equals(service, StringComparison.OrdinalIgnoreCase);
+
     internal static bool IsKinesisService(string service)
         => KinesisService.Equals(service, StringComparison.OrdinalIgnoreCase);