如何在AWS SQS中仅将含特定错误消息的失败消息路由至DLQ？

AWS SQS本身没有内置的基于错误消息内容的DLQ路由规则——默认逻辑是只要消息被重试的次数达到队列配置的MaxReceiveCount，就会被自动转发到DLQ，不管错误类型是什么。

要实现仅将携带特定错误消息的失败消息路由到DLQ，你需要在消费端自己处理逻辑，具体方式如下：

• 消费端自定义错误判断与转发
  当你的消费程序处理消息抛出错误时，先捕获错误并检查错误内容：

  1. 如果是你指定的特定错误（比如"数据库连接超时"这类预设的错误消息），直接调用SQS的SendMessage接口把这条消息手动发送到目标DLQ；
  2. 发送成功后，调用DeleteMessage接口从原队列删除这条消息，避免它被重复处理；
  3. 如果是其他类型的错误，不要手动处理，让消息留在原队列继续重试，直到达到MaxReceiveCount后按默认规则进入DLQ（或者根据你的需求直接丢弃）。

• 注意事项

  • 要确保错误捕获逻辑能精准匹配特定错误消息，避免误判；
  • 手动转发到DLQ时，建议保留原消息的核心属性（如消息ID、发送时间戳、自定义属性等），方便后续排查问题；
  • 务必在转发后删除原队列的消息，否则消息会被重复消费，导致逻辑混乱。

另外，如果你用Lambda作为消费端，也可以在Lambda函数里实现同样的判断逻辑：处理消息时识别特定错误，调用SQS API转发到DLQ，再删除原队列消息；非特定错误则抛出异常，让Lambda自动把消息放回原队列重试。

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