Remove spans with ec2 metadata ip address from metrics

Author: harrryr

awsagentprovider/src/main/java/software/amazon/opentelemetry/javaagent/providers/AwsSpanMetricsProcessor.java

@@ -17,6 +17,7 @@
 
 import static io.opentelemetry.semconv.SemanticAttributes.HTTP_RESPONSE_STATUS_CODE;
 import static io.opentelemetry.semconv.SemanticAttributes.HTTP_STATUS_CODE;
+import static software.amazon.opentelemetry.javaagent.providers.AwsAttributeKeys.AWS_REMOTE_SERVICE;
 import static software.amazon.opentelemetry.javaagent.providers.AwsSpanProcessingUtil.isKeyPresent;
 
 import io.opentelemetry.api.common.Attributes;
@@ -61,6 +62,10 @@ public final class AwsSpanMetricsProcessor implements SpanProcessor {
   private static final int FAULT_CODE_LOWER_BOUND = 500;
   private static final int FAULT_CODE_UPPER_BOUND = 599;
 
+  // EC2 Metadata API IP Address
+  // https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/instancedata-data-retrieval.html#instancedata-inside-access
+  private final String EC2_METADATA_API_IP = "169.254.169.254";
+
   // Metric instruments
   private final LongHistogram errorHistogram;
   private final LongHistogram faultHistogram;
@@ -117,8 +122,10 @@ public void onEnd(ReadableSpan span) {
     Map<String, Attributes> attributeMap =
         generator.generateMetricAttributeMapFromSpan(spanData, resource);
 
-    for (Map.Entry<String, Attributes> attribute : attributeMap.entrySet()) {
-      recordMetrics(span, spanData, attribute.getValue());
+    if (!isEc2MetadataSpan(attributeMap)) {
+      for (Map.Entry<String, Attributes> attribute : attributeMap.entrySet()) {
+        recordMetrics(span, spanData, attribute.getValue());
+      }
     }
   }
 
@@ -177,4 +184,18 @@ private void recordMetrics(ReadableSpan span, SpanData spanData, Attributes attr
       recordLatency(span, attributes);
     }
   }
+
+  private boolean isEc2MetadataSpan(Map<String, Attributes> attributeMap) {
+    if (attributeMap.get(MetricAttributeGenerator.DEPENDENCY_METRIC) != null
+        && attributeMap.get(MetricAttributeGenerator.DEPENDENCY_METRIC).get(AWS_REMOTE_SERVICE)
+            != null
+        && attributeMap
+            .get(MetricAttributeGenerator.DEPENDENCY_METRIC)
+            .get(AWS_REMOTE_SERVICE)
+            .equals(EC2_METADATA_API_IP)) {
+      return true;
+    }
+
+    return false;
+  }
 }