Struct SqsEventExtractor 

pub struct SqsEventExtractor;

Extractor for SQS message events.

SQS events may carry trace context in two locations:

1. message_attributes - W3C traceparent/tracestate injected by OTel-instrumented producers
2. attributes (system attributes) - AWSTraceHeader in X-Ray format set by AWS

This extractor checks both, preferring W3C format when available.

Per OpenTelemetry semantic conventions for messaging systems, this extractor:

• Does NOT set a parent context (returns current context)
• Creates span links for each message’s trace context

This approach is appropriate because messages in a batch may originate from different traces, and the async nature of message queues means span links are more semantically correct than parent-child relationships.

Example

use opentelemetry_lambda_tower::{OtelTracingLayer, SqsEventExtractor};

let layer = OtelTracingLayer::new(SqsEventExtractor::new());

Implementations

impl SqsEventExtractor

pub fn new() -> Self

Creates a new SQS event extractor.

Trait Implementations

impl Clone for SqsEventExtractor

fn clone(&self) -> SqsEventExtractor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqsEventExtractor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SqsEventExtractor

fn default() -> SqsEventExtractor

Returns the “default value” for a type.

impl TraceContextExtractor<SqsEvent> for SqsEventExtractor

fn extract_context(&self, _event: &SqsEvent) -> Context

Extracts parent context for creating child spans.

fn extract_links(&self, event: &SqsEvent) -> Vec<Link>

Extracts span links for async message correlation.

fn trigger_type(&self) -> &'static str

Returns the FaaS trigger type for semantic conventions.

fn span_name(&self, event: &SqsEvent, lambda_ctx: &LambdaContext) -> String

Generates span name based on event and Lambda context.

fn record_attributes(&self, event: &SqsEvent, span: &Span)

Records event-specific attributes on the span.

impl<T: Serialize + Send + Sync + 'static> TraceContextExtractor<SqsEventObj<T>> for SqsEventExtractor

fn extract_context(&self, _event: &SqsEventObj<T>) -> Context

Extracts parent context for creating child spans.

fn extract_links(&self, event: &SqsEventObj<T>) -> Vec<Link>

Extracts span links for async message correlation.

fn trigger_type(&self) -> &'static str

Returns the FaaS trigger type for semantic conventions.

fn span_name( &self, event: &SqsEventObj<T>, lambda_ctx: &LambdaContext, ) -> String

Generates span name based on event and Lambda context.

fn record_attributes(&self, event: &SqsEventObj<T>, span: &Span)

Records event-specific attributes on the span.