diff --git a/plugins/node/opentelemetry-instrumentation-aws-lambda/src/instrumentation.ts b/plugins/node/opentelemetry-instrumentation-aws-lambda/src/instrumentation.ts index c6d63ca86a..e44a8dadc7 100644 --- a/plugins/node/opentelemetry-instrumentation-aws-lambda/src/instrumentation.ts +++ b/plugins/node/opentelemetry-instrumentation-aws-lambda/src/instrumentation.ts @@ -40,9 +40,13 @@ import { } from '@opentelemetry/api'; import { SEMATTRS_FAAS_EXECUTION, - SEMRESATTRS_CLOUD_ACCOUNT_ID, SEMRESATTRS_FAAS_ID, } from '@opentelemetry/semantic-conventions'; +import { + ATTR_FAAS_INVOCATION_ID, + ATTR_CLOUD_ACCOUNT_ID, + ATTR_CLOUD_RESOURCE_ID, +} from '@opentelemetry/semantic-conventions/incubating'; import { ATTR_FAAS_COLDSTART } from '@opentelemetry/semantic-conventions/incubating'; import { @@ -238,11 +242,12 @@ export class AwsLambdaInstrumentation extends InstrumentationBase { span.attributes[SEMATTRS_FAAS_EXECUTION], 'aws_request_id' ); + assert.strictEqual( + span.attributes[ATTR_FAAS_INVOCATION_ID], + 'aws_request_id' + ); assert.strictEqual(span.attributes['faas.id'], 'my_arn'); assert.strictEqual(span.status.code, SpanStatusCode.UNSET); assert.strictEqual(span.status.message, undefined); @@ -75,6 +80,10 @@ const assertSpanFailure = (span: ReadableSpan) => { span.attributes[SEMATTRS_FAAS_EXECUTION], 'aws_request_id' ); + assert.strictEqual( + span.attributes[ATTR_FAAS_INVOCATION_ID], + 'aws_request_id' + ); assert.strictEqual(span.attributes['faas.id'], 'my_arn'); assert.strictEqual(span.status.code, SpanStatusCode.ERROR); assert.strictEqual(span.status.message, 'handler error');