OpenTelemetry interoperability in Java

@Override
public String handleRequest(Object input, Context context) {
    Tracer tracer = GlobalOpenTelemetry.getTracer("instrumentation-library-name", "1.0.0");

    Span span = tracer.spanBuilder("do some work").startSpan();
    try {
        span.setAttribute("foo", "bar");
        // ....
        return "Hello from OpenTelemetry Java!";
    } finally {
        span.end();
    }
}

package com.dynatrace.example.lambda;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.SendMessageResponse;

public class MessageSender implements RequestHandler<Object, Void> {
  private static final SqsClient client = SqsClient.create();

  @Override
  public Void handleRequest(Object input, Context context) {
        final SendMessageResponse resp = client.sendMessage(builder -> builder
                .queueUrl("[your SQS-queue URL]")
                .messageBody("[your payload]")
        );
        System.out.printf("Sent message with ID %s (send request ID %s)%n",
                resp.messageId(),
                resp.responseMetadata().requestId());
    return null;
  }
}

package com.dynatrace.example.lambda;

import java.util.Map;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.amazonaws.services.lambda.runtime.events.SQSEvent;

import io.opentelemetry.api.GlobalOpenTelemetry;
import io.opentelemetry.api.trace.Span;
import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.context.Scope;
import io.opentelemetry.context.propagation.TextMapGetter;

public class MessageIngress implements RequestHandler<SQSEvent, Void> {

    private static final Tracer tracer = GlobalOpenTelemetry.getTracer("message-ingress-app");

    @Override
    public Void handleRequest(SQSEvent input, Context context) {
        for (SQSEvent.SQSMessage message: input.getRecords()) {
            Span span = tracer
                    .spanBuilder(message.getEventSource() + " process")
                    .setSpanKind(SpanKind.CONSUMER) // MUST be either CONSUMER or SERVER
                    .setParent(GlobalOpenTelemetry
                            .getPropagators()
                            .getTextMapPropagator()
                            .extract(
                                io.opentelemetry.context.Context.current(),
                                message.getMessageAttributes(),
                                SqsMessageRecordGetter.INSTANCE))
                    .startSpan();
            try (Scope ignored = span.makeCurrent()) {
                handleMessage(message);
            } catch (Throwable e) {
                span.recordException(e);
                throw e;
            } finally {
                span.end();
            }
        }

        return null;
    }

    private void handleMessage(SQSEvent.SQSMessage message) {
        // This is where your actual handling code would go
        System.out.printf("Handling message with ID %s...%n", message.getMessageId());
    }

    private enum SqsMessageRecordGetter implements TextMapGetter<Map<String, SQSEvent.MessageAttribute>> {
        INSTANCE;

        @Override
        public Iterable<String> keys(Map<String, SQSEvent.MessageAttribute> carrier) {
            return carrier.keySet();
        }

        @Override
        public String get(Map<String, SQSEvent.MessageAttribute> carrier, String key) {
            if (carrier == null) {
                return null;
            }
            SQSEvent.MessageAttribute messageAttribute = carrier.get(key);
            return messageAttribute == null ? null : messageAttribute.getStringValue();
        }
    }
}