Add FaaS exception event extractor helper

Author: trask

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/faas/internal/FaasExceptionEventExtractors.java

@@ -0,0 +1,38 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.instrumentation.api.incubator.semconv.faas.internal;
+
+import com.google.errorprone.annotations.CanIgnoreReturnValue;
+import io.opentelemetry.api.logs.Severity;
+import io.opentelemetry.instrumentation.api.instrumenter.InstrumenterBuilder;
+import io.opentelemetry.instrumentation.api.internal.Experimental;
+
+/**
+ * This class is internal and is hence not for public use. Its APIs are unstable and can change at
+ * any time.
+ */
+public final class FaasExceptionEventExtractors {
+
+  /**
+   * Configures the FaaS invocation exception event name and severity. Only takes effect when
+   * emitting exceptions as logs is enabled via the {@code otel.semconv.exception.signal.preview}
+   * flag.
+   */
+  @CanIgnoreReturnValue
+  public static <REQUEST, RESPONSE>
+      InstrumenterBuilder<REQUEST, RESPONSE> setFaasInvocationExceptionEventExtractor(
+          InstrumenterBuilder<REQUEST, RESPONSE> builder) {
+    Experimental.setExceptionEventExtractor(
+        builder,
+        (logRecordBuilder, context, request) -> {
+          logRecordBuilder.setEventName("faas.invocation.exception");
+          logRecordBuilder.setSeverity(Severity.ERROR);
+        });
+    return builder;
+  }
+
+  private FaasExceptionEventExtractors() {}
+}

instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/internal/AwsLambdaFunctionInstrumenterFactory.java

@@ -5,6 +5,8 @@
 
 package io.opentelemetry.instrumentation.awslambdacore.v1_0.internal;
 
+import static io.opentelemetry.instrumentation.api.incubator.semconv.faas.internal.FaasExceptionEventExtractors.setFaasInvocationExceptionEventExtractor;
+
 import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
 import io.opentelemetry.instrumentation.api.instrumenter.SpanKindExtractor;
@@ -19,11 +21,12 @@ public final class AwsLambdaFunctionInstrumenterFactory {
   public static AwsLambdaFunctionInstrumenter createInstrumenter(OpenTelemetry openTelemetry) {
     return new AwsLambdaFunctionInstrumenter(
         openTelemetry,
-        Instrumenter.builder(
-                openTelemetry,
-                "io.opentelemetry.aws-lambda-core-1.0",
-                AwsLambdaFunctionInstrumenterFactory::spanName)
-            .addAttributesExtractor(new AwsLambdaFunctionAttributesExtractor())
+        setFaasInvocationExceptionEventExtractor(
+                Instrumenter.builder(
+                        openTelemetry,
+                        "io.opentelemetry.aws-lambda-core-1.0",
+                        AwsLambdaFunctionInstrumenterFactory::spanName)
+                    .addAttributesExtractor(new AwsLambdaFunctionAttributesExtractor()))
             .buildInstrumenter(SpanKindExtractor.alwaysServer()));
   }
 

instrumentation/aws-lambda/aws-lambda-events-common-2.2/library/src/main/java/io/opentelemetry/instrumentation/awslambdaevents/common/v2_2/internal/AwsLambdaEventsInstrumenterFactory.java

@@ -5,6 +5,8 @@
 
 package io.opentelemetry.instrumentation.awslambdaevents.common.v2_2.internal;
 
+import static io.opentelemetry.instrumentation.api.incubator.semconv.faas.internal.FaasExceptionEventExtractors.setFaasInvocationExceptionEventExtractor;
+
 import com.amazonaws.services.lambda.runtime.events.APIGatewayProxyRequestEvent;
 import io.opentelemetry.api.OpenTelemetry;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
@@ -24,10 +26,13 @@ public static AwsLambdaFunctionInstrumenter createInstrumenter(
       OpenTelemetry openTelemetry, String instrumentationName, Set<String> knownMethods) {
     return new AwsLambdaFunctionInstrumenter(
         openTelemetry,
-        Instrumenter.builder(
-                openTelemetry, instrumentationName, AwsLambdaEventsInstrumenterFactory::spanName)
-            .addAttributesExtractor(new AwsLambdaFunctionAttributesExtractor())
-            .addAttributesExtractor(new ApiGatewayProxyAttributesExtractor(knownMethods))
+        setFaasInvocationExceptionEventExtractor(
+                Instrumenter.builder(
+                        openTelemetry,
+                        instrumentationName,
+                        AwsLambdaEventsInstrumenterFactory::spanName)
+                    .addAttributesExtractor(new AwsLambdaFunctionAttributesExtractor())
+                    .addAttributesExtractor(new ApiGatewayProxyAttributesExtractor(knownMethods)))
             .buildInstrumenter(SpanKindExtractor.alwaysServer()));
   }