如何在C#中将从SQSQueue消费的SQSMessage直接发送到DLQ

首先明确：SQS的MessageId是服务端自动生成的，你无法给新发送的消息指定这个字段——不管发送到哪个队列，新消息都会生成全新的MessageId。但你可以把原消息的所有元数据（包括原MessageId、EventSource、MessageAttributes等）完整携带到DLQ的消息中，具体有两种可行方案：

方案一：将整个原消息序列化为JSON作为DLQ消息体 #

直接把SQSMessage对象序列化为JSON字符串，作为SendMessageRequest的Body发送到DLQ。这样DLQ消息的Body就包含了原消息的所有信息，后续排查时可以完整解析出原消息的全部元数据。

示例代码（Java）：

// 用Jackson做序列化示例
ObjectMapper objectMapper = new ObjectMapper();
String serializedOriginalMsg = objectMapper.writeValueAsString(originalSqsMessage);

SendMessageRequest dlqSendRequest = SendMessageRequest.builder()
        .queueUrl(dlqQueueUrl)
        .messageBody(serializedOriginalMsg)
        .build();

sqsClient.sendMessage(dlqSendRequest);

方案二：保留原消息体，将元数据存入MessageAttributes #

如果不想修改原消息的Body，可以把关键元数据提取出来，放到新消息的MessageAttributes中。这样Body保留原消息内容，元数据单独存储，方便后续筛选或快速查看。

示例代码（Java）：

Map<String, MessageAttributeValue> dlqMsgAttributes = new HashMap<>();
// 存入原消息ID
dlqMsgAttributes.put("OriginalMessageId", MessageAttributeValue.builder()
        .dataType("String")
        .stringValue(originalSqsMessage.messageId())
        .build());
// 存入事件源
dlqMsgAttributes.put("EventSource", MessageAttributeValue.builder()
        .dataType("String")
        .stringValue(originalSqsMessage.eventSource())
        .build());
// 转存原消息的MessageAttributes（加前缀区分）
originalSqsMessage.messageAttributes().forEach((key, value) -> {
    dlqMsgAttributes.put("Original_" + key, MessageAttributeValue.builder()
            .dataType(value.dataType())
            .stringValue(value.stringValue())
            .binaryValue(value.binaryValue())
            .build());
});

SendMessageRequest dlqSendRequest = SendMessageRequest.builder()
        .queueUrl(dlqQueueUrl)
        .messageBody(originalSqsMessage.body())
        .messageAttributes(dlqMsgAttributes)
        .build();

sqsClient.sendMessage(dlqSendRequest);

注意事项 #

• 新消息的MessageId、SentTimestamp等字段由DLQ队列生成，无法与原消息完全一致，但你已经完整保留了原消息的所有业务元数据，不影响后续问题排查。
• 如果原消息体积较大，序列化整个对象可能触发SQS的消息大小限制（最大256KB），这种情况下优先选择方案二，只转存关键元数据。

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