Look at first record eventSource in aws lambda event Records array to determine if it is an sqs event

wpessers · wpessers · commit 412de1f9aa77 · 2025-08-17T00:26:42.000+02:00
diff --git a/packages/instrumentation-aws-lambda/src/instrumentation.ts b/packages/instrumentation-aws-lambda/src/instrumentation.ts
@@ -287,7 +287,7 @@ export class AwsLambdaInstrumentation extends InstrumentationBase<AwsLambdaInstr
       }
 
       return otelContext.with(trace.setSpan(parent, span), () => {
-        if (event.Records) {
+        if (event.Records && event.Records[0].eventSource === 'aws:sqs') {
           const messages = event.Records;
           const queueArn = messages[0]?.eventSourceARN;
           const queueName = queueArn?.split(':').pop() ?? 'unknown';

Original file line number	Diff line number	Diff line change
`@@ -287,7 +287,7 @@ export class AwsLambdaInstrumentation extends InstrumentationBase<AwsLambdaInstr`
`287`	`287`	`}`
`288`	`288`
`289`	`289`	`return otelContext.with(trace.setSpan(parent, span), () => {`
`290`		`- if (event.Records) {`
	`290`	`+ if (event.Records && event.Records[0].eventSource === 'aws:sqs') {`
`291`	`291`	`const messages = event.Records;`
`292`	`292`	`const queueArn = messages[0]?.eventSourceARN;`
`293`	`293`	`const queueName = queueArn?.split(':').pop() ?? 'unknown';`