如何从DLQ获取SQS源队列消息处理的错误信息？

核心结论 #

默认情况下，AWS SQS不会自动将源队列中业务处理的错误信息（如代码异常、业务失败原因）传递到DLQ。要获取这类信息，需要主动在处理失败时给消息附加自定义元数据，同时SQS会提供几个内置的重试相关属性供参考。

具体实现方式 #

1. 手动添加自定义错误属性到消息 #

在源队列处理消息失败时，将错误详情（异常栈、错误码、失败场景描述等）添加到消息的MessageAttributes中，再通过ChangeMessageVisibility延长消息可见性让其继续重试。当消息达到重试上限被移至DLQ时，这些自定义属性会随消息一起传递。

示例代码（Java AWS SDK v2）：

// 处理消息失败后，构建错误属性
Map<String, MessageAttributeValue> errorAttrs = new HashMap<>();
errorAttrs.put("ErrorDetail", MessageAttributeValue.builder()
        .dataType("String")
        .stringValue("OrderServiceException: 库存不足，商品ID: 1001")
        .build());
errorAttrs.put("RetryAttempts", MessageAttributeValue.builder()
        .dataType("Number")
        .stringValue("3")
        .build());

// 更新消息可见性，等待下一次重试
sqsClient.changeMessageVisibility(ChangeMessageVisibilityRequest.builder()
        .queueUrl(sourceQueueUrl)
        .receiptHandle(receiptHandle)
        .visibilityTimeout(60) // 60秒后再次可见
        .build());

在DLQ中接收消息时，直接读取MessageAttributes即可获取错误信息。

2. 利用SQS内置的系统属性 #

SQS会自动为每个消息添加几个系统属性，可用于判断重试情况，但无法提供业务错误详情：

• ApproximateReceiveCount：消息被接收的总次数（即重试次数）
• SentTimestamp：消息首次发送到源队列的时间戳
• ApproximateFirstReceiveTimestamp：消息首次被源队列消费者接收的时间戳

这些属性无需手动添加，DLQ中的消息会自动携带，可通过AWS SDK直接读取。

关于消息头的说明 #

SQS没有传统HTTP式的"消息头"概念，所有元数据都通过MessageAttributes承载：

• 系统属性由SQS自动生成，包含重试、时间等基础信息；
• 自定义属性需要开发者主动添加，是传递业务错误信息的唯一方式。

LocalStack测试注意事项 #

LocalStack对SQS的属性传递可能存在版本兼容问题，建议：

• 升级LocalStack到最新稳定版；
• 测试时优先验证自定义属性的传递是否正常，排除模拟环境的差异；
• 若LocalStack中属性传递异常，可先在真实AWS环境做小范围验证，确认逻辑正确性。

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