fix remote resource identifier for new resources

Author: ezhang6811

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

@@ -427,12 +427,12 @@ private static void SetRemoteResourceTypeAndIdentifier(Activity span, ActivityTa
             else if (IsKeyPresent(span, AttributeAWSSecretsManagerSecretArn))
             {
                 remoteResourceType = NormalizedSecretsManagerServiceName + "::Secret";
-                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSSecretsManagerSecretArn));
+                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSSecretsManagerSecretArn)).Split(":").Last();
             }
             else if (IsKeyPresent(span, AttributeAWSSNSTopicArn))
             {
                 remoteResourceType = NormalizedSNSServiceName + "::Topic";
-                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSSNSTopicArn));
+                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSSNSTopicArn)).Split(":").Last();
             }
             else if (IsKeyPresent(span, AttributeAWSSQSQueueName))
             {
@@ -449,12 +449,12 @@ private static void SetRemoteResourceTypeAndIdentifier(Activity span, ActivityTa
             else if (IsKeyPresent(span, AttributeAWSStepFunctionsActivityArn))
             {
                 remoteResourceType = NormalizedStepFunctionsName + "::Activity";
-                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSStepFunctionsActivityArn));
+                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSStepFunctionsActivityArn)).Split(":").Last();
             }
             else if (IsKeyPresent(span, AttributeAWSStepFunctionsStateMachineArn))
             {
                 remoteResourceType = NormalizedStepFunctionsName + "::StateMachine";
-                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSStepFunctionsStateMachineArn));
+                remoteResourceIdentifier = EscapeDelimiters((string?)span.GetTagItem(AttributeAWSStepFunctionsStateMachineArn)).Split(":").Last();
             }
             else if (IsKeyPresent(span, AttributeAWSBedrockGuardrailId))
             {

test/contract-tests/tests/test/amazon/awssdk/awssdk_test.py

@@ -335,7 +335,7 @@ def test_secretsmanager_create_secret(self):
             remote_service="AWS::SecretsManager",
             remote_operation="CreateSecret",
             remote_resource_type="AWS::SecretsManager::Secret",
-            remote_resource_identifier=r"arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-[a-zA-Z0-9]{6}$",
+            remote_resource_identifier=r"test-secret-[a-zA-Z0-9]{6}$",
             request_response_specific_attributes={
                 _AWS_SECRETSMANAGER_SECRET_ARN: r"arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-[a-zA-Z0-9]{6}$",
             },
@@ -353,7 +353,7 @@ def test_secretsmanager_get_secret_value(self):
             remote_service="AWS::SecretsManager",
             remote_operation="GetSecretValue",
             remote_resource_type="AWS::SecretsManager::Secret",
-            remote_resource_identifier=r"arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-[a-zA-Z0-9]{6}$",
+            remote_resource_identifier=r"test-secret-[a-zA-Z0-9]{6}$",
             request_response_specific_attributes={
                 _AWS_SECRETSMANAGER_SECRET_ARN: r"arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-[a-zA-Z0-9]{6}$",
             },
@@ -371,7 +371,7 @@ def test_secretsmanager_error(self):
             remote_service="AWS::SecretsManager",
             remote_operation="DescribeSecret",
             remote_resource_type="AWS::SecretsManager::Secret",
-            remote_resource_identifier="arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-error",
+            remote_resource_identifier="test-secret-error",
             request_response_specific_attributes={
                 _AWS_SECRETSMANAGER_SECRET_ARN: "arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-error",
             },
@@ -390,7 +390,7 @@ def test_secretsmanager_error(self):
     #         remote_service="AWS::SecretsManager",
     #         remote_operation="CreateSecret",
     #         remote_resource_type="AWS::SecretsManager::Secret",
-    #         remote_resource_identifier="arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-error",
+    #         remote_resource_identifier="test-secret-error",
     #         request_response_specific_attributes={
     #             _AWS_SECRETSMANAGER_SECRET_ARN: "arn:aws:secretsmanager:us-east-1:000000000000:secret:test-secret-error",
     #         },
@@ -407,7 +407,7 @@ def test_sns_publish(self):
             remote_service="AWS::SNS",
             remote_operation="Publish",
             remote_resource_type="AWS::SNS::Topic",
-            remote_resource_identifier="arn:aws:sns:us-east-1:000000000000:test-topic",
+            remote_resource_identifier="test-topic",
             request_response_specific_attributes={
                 _AWS_SNS_TOPIC_ARN: "arn:aws:sns:us-east-1:000000000000:test-topic",
             },
@@ -424,7 +424,7 @@ def test_sns_error(self):
             remote_service="AWS::SNS",
             remote_operation="Publish",
             remote_resource_type="AWS::SNS::Topic",
-            remote_resource_identifier="arn:aws:sns:us-east-1:000000000000:test-topic-error",
+            remote_resource_identifier="test-topic-error",
             request_response_specific_attributes={
                 _AWS_SNS_TOPIC_ARN: "arn:aws:sns:us-east-1:000000000000:test-topic-error",
             },
@@ -442,7 +442,7 @@ def test_sns_error(self):
     #         remote_service="AWS::SNS",
     #         remote_operation="GetTopicAttributes",
     #         remote_resource_type="AWS::SNS::Topic",
-    #         remote_resource_identifier="arn:aws:sns:us-east-1:000000000000:invalid-topic",
+    #         remote_resource_identifier="invalid-topic",
     #         request_response_specific_attributes={
     #            _AWS_SNS_TOPIC_ARN: "arn:aws:sns:us-east-1:000000000000:invalid-topic",},
     #         span_name="SNS.GetTopicAttributes"
@@ -459,7 +459,7 @@ def test_stepfunctions_describe_state_machine(self):
             remote_service="AWS::StepFunctions",
             remote_operation="DescribeStateMachine",
             remote_resource_type="AWS::StepFunctions::StateMachine",
-            remote_resource_identifier="arn:aws:states:us-east-1:000000000000:stateMachine:test-state-machine",
+            remote_resource_identifier="test-state-machine",
             request_response_specific_attributes={
                 _AWS_STEPFUNCTIONS_STATE_MACHINE_ARN: "arn:aws:states:us-east-1:000000000000:stateMachine:test-state-machine",
             },
@@ -477,7 +477,7 @@ def test_stepfunctions_describe_activity(self):
             remote_service="AWS::StepFunctions",
             remote_operation="DescribeActivity",
             remote_resource_type="AWS::StepFunctions::Activity",
-            remote_resource_identifier="arn:aws:states:us-east-1:000000000000:activity:test-activity",
+            remote_resource_identifier="test-activity",
             request_response_specific_attributes={
                 _AWS_STEPFUNCTIONS_ACTIVITY_ARN: "arn:aws:states:us-east-1:000000000000:activity:test-activity",
             },
@@ -495,7 +495,7 @@ def test_stepfunctions_error(self):
             remote_service="AWS::StepFunctions",
             remote_operation="DescribeStateMachine",
             remote_resource_type="AWS::StepFunctions::StateMachine",
-            remote_resource_identifier="arn:aws:states:us-east-1:000000000000:stateMachine:error-state-machine",
+            remote_resource_identifier="error-state-machine",
             request_response_specific_attributes={
                 _AWS_STEPFUNCTIONS_STATE_MACHINE_ARN: "arn:aws:states:us-east-1:000000000000:stateMachine:error-state-machine",
             },
@@ -515,7 +515,7 @@ def test_stepfunctions_error(self):
     #         remote_service="AWS::StepFunctions",
     #         remote_operation="ListStateMachineVersions",
     #         remote_resource_type="AWS::StepFunctions::StateMachine",
-    #         remote_resource_identifier="arn:aws:states:us-east-1:000000000000:stateMachine:invalid-state-machine",
+    #         remote_resource_identifier="invalid-state-machine",
     #         request_response_specific_attributes={
     #            _AWS_STEPFUNCTIONS_STATE_MACHINE_ARN: "arn:aws:states:us-east-1:000000000000:stateMachine:invalid-state-machine",},
     #         span_name="SFN.ListStateMachineVersions",