重新处理AWS SQS死信队列消息

Question

我使用aws sdk将lambda中失败的消息发送到死信队列。我希望在将消息发送回主队列进行重新处理之前等待几个小时。我有一个lambda连接到我的死信队列。我可以使用delay将消息发送到死信队列。但最大延迟是15分钟。但是我想等更多的时间。以前有人这么做过吗？

Answer 1

Amazon SQS是，不打算以这种方式使用。它的主要用途是存储消息，然后在请求时将其返回。

其他一些选项：

• 将邮件存储在数据库中，并让应用程序根据时间戳字段搜索相关邮件，或者
• 在AWS步骤函数(具有延迟功能)上执行一些棘手的延迟操作

Answer 2

如this answer所示，您可以延长延迟，方法是为每条消息添加一个时间戳，并只处理目前在队列中的那些消息。

message = SQS.poll_messages
if message.perform_message_at > Time.now
   SQS.push_to_queue({perform_message_at : "Thursday November 
   2022"},delay:15 mins)
else
   process_message(message)
end