Skip to content

Commit 693a09e

Browse files
committed
fix ecs
1 parent dd7aa29 commit 693a09e

File tree

1 file changed

+38
-38
lines changed

1 file changed

+38
-38
lines changed

detectors/node/opentelemetry-resource-detector-aws/src/detectors/AwsEcsDetectorSync.ts

Lines changed: 38 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -23,26 +23,26 @@ import {
2323
ResourceAttributes,
2424
} from '@opentelemetry/resources';
2525
import {
26-
SEMRESATTRS_CLOUD_PROVIDER,
27-
SEMRESATTRS_CLOUD_PLATFORM,
28-
SEMRESATTRS_CONTAINER_ID,
29-
SEMRESATTRS_CONTAINER_NAME,
30-
SEMRESATTRS_AWS_ECS_CONTAINER_ARN,
31-
SEMRESATTRS_AWS_ECS_CLUSTER_ARN,
32-
SEMRESATTRS_AWS_ECS_LAUNCHTYPE,
33-
SEMRESATTRS_AWS_ECS_TASK_ARN,
34-
SEMRESATTRS_AWS_ECS_TASK_FAMILY,
35-
SEMRESATTRS_AWS_ECS_TASK_REVISION,
36-
SEMRESATTRS_CLOUD_ACCOUNT_ID,
37-
SEMRESATTRS_CLOUD_REGION,
38-
SEMRESATTRS_CLOUD_AVAILABILITY_ZONE,
39-
SEMRESATTRS_AWS_LOG_GROUP_NAMES,
40-
SEMRESATTRS_AWS_LOG_GROUP_ARNS,
41-
SEMRESATTRS_AWS_LOG_STREAM_NAMES,
42-
SEMRESATTRS_AWS_LOG_STREAM_ARNS,
43-
CLOUDPROVIDERVALUES_AWS,
44-
CLOUDPLATFORMVALUES_AWS_ECS,
45-
} from '@opentelemetry/semantic-conventions';
26+
ATTR_CLOUD_PROVIDER,
27+
ATTR_CLOUD_PLATFORM,
28+
ATTR_CONTAINER_ID,
29+
ATTR_CONTAINER_NAME,
30+
ATTR_AWS_ECS_CONTAINER_ARN,
31+
ATTR_AWS_ECS_CLUSTER_ARN,
32+
ATTR_AWS_ECS_LAUNCHTYPE,
33+
ATTR_AWS_ECS_TASK_ARN,
34+
ATTR_AWS_ECS_TASK_FAMILY,
35+
ATTR_AWS_ECS_TASK_REVISION,
36+
ATTR_CLOUD_ACCOUNT_ID,
37+
ATTR_CLOUD_REGION,
38+
ATTR_CLOUD_AVAILABILITY_ZONE,
39+
ATTR_AWS_LOG_GROUP_NAMES,
40+
ATTR_AWS_LOG_GROUP_ARNS,
41+
ATTR_AWS_LOG_STREAM_NAMES,
42+
ATTR_AWS_LOG_STREAM_ARNS,
43+
CLOUD_PROVIDER_VALUE_AWS,
44+
CLOUD_PLATFORM_VALUE_AWS_ECS,
45+
} from '@opentelemetry/semantic-conventions/incubating';
4646
// Patch until the OpenTelemetry SDK is updated to ship this attribute
4747
import { SemanticResourceAttributes as AdditionalSemanticResourceAttributes } from './SemanticResourceAttributes';
4848
import * as http from 'http';
@@ -86,8 +86,8 @@ export class AwsEcsDetectorSync implements DetectorSync {
8686

8787
try {
8888
let resource = new Resource({
89-
[SEMRESATTRS_CLOUD_PROVIDER]: CLOUDPROVIDERVALUES_AWS,
90-
[SEMRESATTRS_CLOUD_PLATFORM]: CLOUDPLATFORMVALUES_AWS_ECS,
89+
[ATTR_CLOUD_PROVIDER]: CLOUD_PROVIDER_VALUE_AWS,
90+
[ATTR_CLOUD_PLATFORM]: CLOUD_PLATFORM_VALUE_AWS_ECS,
9191
}).merge(await AwsEcsDetectorSync._getContainerIdAndHostnameResource());
9292

9393
const metadataUrl = getEnv().ECS_CONTAINER_METADATA_URI_V4;
@@ -146,8 +146,8 @@ export class AwsEcsDetectorSync implements DetectorSync {
146146

147147
if (hostName || containerId) {
148148
return new Resource({
149-
[SEMRESATTRS_CONTAINER_NAME]: hostName || '',
150-
[SEMRESATTRS_CONTAINER_ID]: containerId || '',
149+
[ATTR_CONTAINER_NAME]: hostName || '',
150+
[ATTR_CONTAINER_ID]: containerId || '',
151151
});
152152
}
153153

@@ -177,21 +177,21 @@ export class AwsEcsDetectorSync implements DetectorSync {
177177

178178
// https://github.com/open-telemetry/semantic-conventions/blob/main/semantic_conventions/resource/cloud_provider/aws/ecs.yaml
179179
const attributes: ResourceAttributes = {
180-
[SEMRESATTRS_AWS_ECS_CONTAINER_ARN]: containerArn,
181-
[SEMRESATTRS_AWS_ECS_CLUSTER_ARN]: clusterArn,
182-
[SEMRESATTRS_AWS_ECS_LAUNCHTYPE]: launchType?.toLowerCase(),
183-
[SEMRESATTRS_AWS_ECS_TASK_ARN]: taskArn,
184-
[SEMRESATTRS_AWS_ECS_TASK_FAMILY]: taskMetadata['Family'],
185-
[SEMRESATTRS_AWS_ECS_TASK_REVISION]: taskMetadata['Revision'],
186-
187-
[SEMRESATTRS_CLOUD_ACCOUNT_ID]: accountId,
188-
[SEMRESATTRS_CLOUD_REGION]: region,
180+
[ATTR_AWS_ECS_CONTAINER_ARN]: containerArn,
181+
[ATTR_AWS_ECS_CLUSTER_ARN]: clusterArn,
182+
[ATTR_AWS_ECS_LAUNCHTYPE]: launchType?.toLowerCase(),
183+
[ATTR_AWS_ECS_TASK_ARN]: taskArn,
184+
[ATTR_AWS_ECS_TASK_FAMILY]: taskMetadata['Family'],
185+
[ATTR_AWS_ECS_TASK_REVISION]: taskMetadata['Revision'],
186+
187+
[ATTR_CLOUD_ACCOUNT_ID]: accountId,
188+
[ATTR_CLOUD_REGION]: region,
189189
[AdditionalSemanticResourceAttributes.CLOUD_RESOURCE_ID]: containerArn,
190190
};
191191

192192
// The availability zone is not available in all Fargate runtimes
193193
if (availabilityZone) {
194-
attributes[SEMRESATTRS_CLOUD_AVAILABILITY_ZONE] = availabilityZone;
194+
attributes[ATTR_CLOUD_AVAILABILITY_ZONE] = availabilityZone;
195195
}
196196

197197
return new Resource(attributes);
@@ -222,10 +222,10 @@ export class AwsEcsDetectorSync implements DetectorSync {
222222
const logsStreamArn = `arn:aws:logs:${logsRegion}:${awsAccount}:log-group:${logsGroupName}:log-stream:${logsStreamName}`;
223223

224224
return new Resource({
225-
[SEMRESATTRS_AWS_LOG_GROUP_NAMES]: [logsGroupName],
226-
[SEMRESATTRS_AWS_LOG_GROUP_ARNS]: [logsGroupArn],
227-
[SEMRESATTRS_AWS_LOG_STREAM_NAMES]: [logsStreamName],
228-
[SEMRESATTRS_AWS_LOG_STREAM_ARNS]: [logsStreamArn],
225+
[ATTR_AWS_LOG_GROUP_NAMES]: [logsGroupName],
226+
[ATTR_AWS_LOG_GROUP_ARNS]: [logsGroupArn],
227+
[ATTR_AWS_LOG_STREAM_NAMES]: [logsStreamName],
228+
[ATTR_AWS_LOG_STREAM_ARNS]: [logsStreamArn],
229229
});
230230
}
231231

0 commit comments

Comments
 (0)