amazon-web-services - SQS - 交货延迟 30 分钟

标签 amazon-web-services amazon-sqs

从 SQS 的文档中,我们可以配置一条消息向其消费者隐藏的最大时间延迟是 15 分钟 - http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-delay-queues.html

假设如果我需要将消息隐藏一天,模式是什么?
例如。我想模仿每天的 cron 来做一些 Action 。

谢谢

最佳答案

最简单的方法如下:

SQS.push_to_queue({perform_message_at : "Thursday November 2022"},delay: 15 mins)

在你的 worker 里面
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

基本上将消息以最大延迟推回队列,并且仅在其处理时间小于当前时间时才对其进行处理。

哈。

关于amazon-web-services - SQS - 交货延迟 30 分钟,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31881470/

相关文章:

php - Amazon SQS 字符编码问题

hadoop - s3distcp 的多个源文件

amazon-web-services - 从 S3 加载 Redshift(带分区)

amazon-web-services - 无法复制消息时的 AWS SQS 标准队列或 FIFO 队列?

amazon-web-services - SQS 用多条记录/消息触发 Lambda?

amazon-web-services - 将 SQS 与/Dead letter 和 Lambda 一起使用时,为什么在 lambda 因运行时异常而失败后消息仍保持 "in flight"5 分钟?

amazon-web-services - Logstash:将消息批量大小限制为 10MB

mysql - (MySQL) 复制有 bin-log 吗?

amazon-web-services - 如何使用一个 CloudFormation 堆栈中的 SQS 队列作为另一个 CloudFormation 堆栈中的 lambda 函数的触发器?

python - (python/boto sqs) UnicodeDecodeError : 'ascii' codec can't decode byte 0xc3 in position 5: ordinal not in range(128)