如何配置AWS SQS自动将未消费消息移至死信队列？

嘿，Ido！你的需求是完全可行的，但得分两种场景来配置——得先明确你说的“超过1小时未被消费”具体是哪种情况：

场景1：消息被取出后1小时没处理完，自动进死信 #

这种是SQS原生就支持的，你大概率是漏了Visibility Timeout和Redrive Policy的组合配置，具体操作如下：

• 把队列的Visibility Timeout设为3600秒（1小时）：这个参数的意思是，当消费者把消息取走后，这条消息会在主队列里“隐藏”这么久。如果消费者在这段时间内没删掉消息（说明处理超时了），消息会自动回到主队列。
• 配置死信队列的Redrive Policy，把maxReceiveCount设为1：这个参数是消息最多能被放回主队列的次数。设成1的话，一旦消息因为超时回到队列，就会直接被转至死信队列，完美实现你要的“取出后1小时未处理自动进死信”的效果。

具体在控制台操作的话：

• 编辑主队列时，找到「Visibility timeout」输入3600；
• 在「Dead-letter queue」区域，勾选启用，选择你的死信队列，然后把「Maximum receives」设为1就行。

场景2：消息进队后1小时没人取，自动进死信 #

这种场景SQS没有直接的原生配置（毕竟SQS默认是把消息保留最多14天，不会主动把没被取走的消息转死信），但可以用Lambda+EventBridge来实现：

• 写一个Lambda函数，每隔一段时间（比如5分钟）去扫主队列里的消息，找出创建时间超过1小时的；
• 把这些消息发送到死信队列，然后删掉主队列里的原消息；
• 用Amazon EventBridge（原CloudWatch Events）给这个Lambda设个定时触发，让它定期执行。

⚠️ 注意：这种方式要做好消息的幂等性处理，确保消息成功转至死信后再删除主队列里的，避免丢消息。

总结一下 #

如果你的需求是“消息被取走后超时没处理自动进死信”，那调整Visibility Timeout和Redrive Policy的maxReceiveCount就搞定了，这应该是你之前没注意到的关键配置；如果是“消息进队后没人取超时进死信”，就得靠Lambda+EventBridge来补全功能啦。

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