AWS Lambda Runtime internal handlers need to be ignored from being in…

…strumented and so traced. Otherwise, there might be double root spans.

instrumentation/aws-lambda/aws-lambda-core-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/awslambdacore/v1_0/AwsLambdaRequestHandlerInstrumentation.java

@@ -10,7 +10,9 @@
 import static io.opentelemetry.javaagent.instrumentation.awslambdacore.v1_0.AwsLambdaInstrumentationHelper.functionInstrumenter;
 import static net.bytebuddy.matcher.ElementMatchers.isMethod;
 import static net.bytebuddy.matcher.ElementMatchers.isPublic;
+import static net.bytebuddy.matcher.ElementMatchers.nameStartsWith;
 import static net.bytebuddy.matcher.ElementMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.not;
 import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
 
 import com.amazonaws.services.lambda.runtime.Context;
@@ -35,7 +37,8 @@ public ElementMatcher<ClassLoader> classLoaderOptimization() {
 
   @Override
   public ElementMatcher<TypeDescription> typeMatcher() {
-    return implementsInterface(named("com.amazonaws.services.lambda.runtime.RequestHandler"));
+    return implementsInterface(named("com.amazonaws.services.lambda.runtime.RequestHandler"))
+        .and(not(nameStartsWith("com.amazonaws.services.lambda.runtime.api.client")));
   }
 
   @Override

instrumentation/aws-lambda/aws-lambda-core-1.0/javaagent/src/test/java/com/amazonaws/services/lambda/runtime/api/client/AWSLambdaInternalRequestHandler.java

@@ -0,0 +1,23 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package com.amazonaws.services.lambda.runtime.api.client;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+
+public class AWSLambdaInternalRequestHandler implements RequestHandler<String, String> {
+
+  private final RequestHandler<String, String> requestHandler;
+
+  public AWSLambdaInternalRequestHandler(RequestHandler<String, String> requestHandler) {
+    this.requestHandler = requestHandler;
+  }
+
+  @Override
+  public String handleRequest(String input, Context context) {
+    return requestHandler.handleRequest(input, context);
+  }
+}

instrumentation/aws-lambda/aws-lambda-core-1.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/awslambdacore/v1_0/AwsLambdaTest.java

@@ -5,14 +5,19 @@
 
 package io.opentelemetry.javaagent.instrumentation.awslambdacore.v1_0;
 
+import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
 import static org.assertj.core.api.Assertions.assertThat;
 
 import com.amazonaws.services.lambda.runtime.Context;
 import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.api.client.AWSLambdaInternalRequestHandler;
+import io.opentelemetry.api.trace.SpanKind;
 import io.opentelemetry.instrumentation.awslambdacore.v1_0.AbstractAwsLambdaTest;
 import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
 import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.semconv.SemanticAttributes;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 public class AwsLambdaTest extends AbstractAwsLambdaTest {
@@ -35,6 +40,23 @@ void tearDown() {
     assertThat(testing.forceFlushCalled()).isTrue();
   }
 
+  @Test
+  void awsLambdaInternalHandlerIgnoredAndUserHandlerTraced() {
+    RequestHandler<String, String> handler = new AWSLambdaInternalRequestHandler(handler());
+    String result = handler.handleRequest("hello", context());
+    assertThat(result).isEqualTo("world");
+
+    testing()
+        .waitAndAssertTraces(
+            trace ->
+                trace.hasSpansSatisfyingExactly(
+                    span ->
+                        span.hasName("my_function")
+                            .hasKind(SpanKind.SERVER)
+                            .hasAttributesSatisfyingExactly(
+                                equalTo(SemanticAttributes.FAAS_INVOCATION_ID, "1-22-333"))));
+  }
+
   private static final class TestRequestHandler implements RequestHandler<String, String> {
 
     @Override

instrumentation/aws-lambda/aws-lambda-core-1.0/testing/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/AbstractAwsLambdaTest.java

@@ -53,6 +53,10 @@ void tearDown() {
     assertThat(testing().forceFlushCalled()).isTrue();
   }
 
+  protected Context context() {
+    return context;
+  }
+
   @Test
   void handlerTraced() {
     String result = handler().handleRequest("hello", context);