python - 在 AWS SQS 队列中连续读取数据

Question

我对 AWS SQS 队列还很陌生，目前正在使用 boto。我注意到，当我尝试在 while 循环中读取充满消息的队列时，我看到在读取 10-25 条消息后，队列不会返回任何消息(即使队列有超过 1000 条消息)。几秒钟后或停止并重新启动程序后，它开始填充另一组 10-25 条消息。虽然真实: read_queue()//已与所需队列建立连接。

关于此行为的任何想法或为我指明正确的方向。只是重申我才刚接触 SQS 几天!!

谢谢

Answer 1

这就是 SQS 队列默认工作的方式(短轮询)。如果您在设置队列后未更改任何设置，则默认设置是从机器的加权随机抽样中获取消息。如果您使用的机器不止一台，并且想要当时可以使用的所有消息(跨所有机器)，则需要使用长轮询。 See the Amazon documentation here.我不认为 boto 直接支持 ATM。