32得票6回答
如何在Lambda中批量失败特定的SQS消息?

我有一个带SQS触发器的Lambda。当它被触发时,来自SQS的一批记录会进入(通常一次约有10个)。如果我从处理程序返回失败状态代码,则所有10条消息都将重试。如果我返回成功代码,则它们将全部从队列中删除。如果这10条消息中有1条失败了,并且我想重试只有那一条,该怎么办?exports.ha...

30得票6回答
持续监听 AWS SQS 消息的模式

我有一个简单的类名叫做QueueService,其中包含一些方法,这些方法包装了AWS SQS SDK for Java中的方法。例如:public ArrayList<Hashtable<String, String>> receiveMessages(String ...

30得票3回答
亚马逊 SQS 或任何队列服务的可能用例是什么?

因为我们公司的整个基础架构都是基于亚马逊的AWS,所以我一直在努力获取AWS。一个组件我从来没有能够正确理解的是队列服务,我已经在谷歌上搜寻了很多,但我还没有得到令人满意的答案。我觉得Cron job和队列服务在某种程度上很相似,如果我错了请纠正我。 那么SQS到底是做什么的呢?据我所知,它...

30得票1回答
为什么CeleryCAM不能与Amazon SQS配合使用?

我正在使用Celery 2.4.6和django-celery 2.4.2。 当我按照这个问题的解决方案配置Celery来使用Amazon SQS时:Celery with Amazon SQS 我在Django管理页面的celerycam表中看不到任何内容。如果我切换回RabbitMQ,...

29得票4回答
AWS SQS中的可见性超时是什么意思?

"Visibility Timeout" 是指 Amazon SQS 服务中的什么意思?哪些因素确定了此字段的理想值? 我查看了 http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/Welcome...

28得票4回答
AWS SQS未接收到SNS消息

我创建了一个SNS主题,通过cli发布所有来自Cloudformation的信息。然而,当我检查队列时,它没有接收到任何SNS消息。我通过订阅我的电子邮件来验证SNS是否工作,因此问题似乎在队列和SNS之间的连接上。但是,我找不到我语法方面的任何问题。据我所知,我已经精确地遵循了Amazon的...

28得票1回答
亚马逊 SQS 消息多次投递

我知道为了实现广泛的可扩展性和可靠性,SQS需要进行大量的资源并行处理。即使是小队列,它也会使用冗余服务器,甚至将发布到队列中的消息存储为多个副本。这些因素防止了像RabbitMQ一样的精确一次性交付。我甚至见过已删除的消息被传送的情况。 对于开发人员来说,影响是他们需要准备好接收多个消息传...

28得票4回答
如何在 SNS 订阅中添加 SQS 消息属性?

AWS SNS和SQS的文档中有关于消息属性的章节。但是没有解释如何在将队列订阅到SNS主题时设置SQS的消息属性。 是否有一种方法可以配置AWS SNS以向通过订阅发送的SQS消息添加特定的消息属性?

27得票2回答
AWS SQS 消息保留期限

根据文档,SQS消息最大保留期限(MessageRetentionPeriod)为14天。超过此时间后,消息将从队列中被删除。 在SQS中是否有一种方法可以在其保留期限到期后不丢失这些消息?例如,使用死信队列是否可行并不清楚。

27得票3回答
从AWS SQS队列中轮询并删除已接收消息的最佳实践是什么?

我有一个SQS队列,它不断地被数据消费者填充,现在我正在尝试使用Python的boto创建从SQS中拉取这些数据的服务。 我的设计方式是我将有10-20个线程都尝试从SQS队列中读取消息,然后在对数据进行操作(业务逻辑)之前做他们需要做的事情,完成后返回到队列获取下一批数据。如果没有数据,它...