AWS Lambda与SQS链路追踪无Links字段问题求助（OpenTelemetry）

核心原因 #

AWS OTel Python层不会自动将Trace上下文注入SQS消息，也不会自动从消息中提取上下文创建Link。必须手动实现上下文的传递逻辑，否则Producer和Consumer的Trace会完全独立。

修复步骤 #

1. Producer Lambda：注入Trace上下文到SQS消息属性 #

在发送SQS消息时，将当前Span的Trace上下文序列化为traceparent属性（遵循W3C标准）：

import boto3
from opentelemetry.trace import get_current_span, format_trace_context

sqs_client = boto3.client("sqs")

def lambda_handler(event, context):
    # 获取当前Span的上下文并序列化
    current_span = get_current_span()
    trace_context_str = format_trace_context(current_span.get_span_context())
    
    # 发送消息时添加traceparent属性
    sqs_client.send_message(
        QueueUrl="你的SQS队列URL",
        MessageBody="业务消息内容",
        MessageAttributes={
            "traceparent": {
                "StringValue": trace_context_str,
                "DataType": "String"
            }
        }
    )
    return {"statusCode": 200}

2. Consumer Lambda：提取上下文并创建Link #

从SQS消息属性中解析traceparent，创建Link关联上游Trace：

from opentelemetry.trace import get_tracer, parse_trace_context, Link

tracer = get_tracer(__name__)

def lambda_handler(event, context):
    for record in event["Records"]:
        # 提取traceparent属性
        traceparent = record["messageAttributes"]["traceparent"]["stringValue"]
        upstream_span_context = parse_trace_context(traceparent)
        
        # 启动Span时关联上游Link
        with tracer.start_as_current_span(
            "处理SQS消息",
            links=[Link(upstream_span_context)]
        ) as span:
            # 你的消息处理逻辑
            span.set_attribute("消息内容", record["body"])
    return {"statusCode": 200}

3. 验证Lambda环境配置 #

确保两个Lambda都配置了以下环境变量：

• AWS_LAMBDA_EXEC_WRAPPER: /opt/otel-instrument（启用AWS OTel自动初始化）
• OTEL_SERVICE_NAME: 分别设置为producer-lambda和consumer-lambda（区分服务）

4. 检查消息传递是否正常 #

• 在SQS控制台查看Producer发送的消息，确认traceparent属性存在且格式正确（格式为00-<trace-id>-<span-id>-01）
• 查看Consumer的Lambda日志，确认没有解析traceparent的异常

额外说明 #

你使用的AWS OTel Python 1.16.0版本不支持SQS链路的自动上下文传递，必须手动实现上述代码逻辑。后续版本可能会支持自动仪器化，但当前版本需要手动处理。

内容的提问来源于stack exchange，提问作者shuwpan