pika - 使用 pika.BlockingConnection 我想从队列中消费消息然后退出

Question

我使用 pika.BlockingConnection 和 channel.start_sumption() 编写了一个消费者，它使用来自特定队列的消息，当消息从队列中耗尽时，消费者无限期地等待下一条消息。

有没有一种方法可以指定某种超时持续时间，如果消费者在特定时间段内没有从队列中获取消息，则 start_sumption() 将正常退出该持续时间。

我正在使用 python 3.7.4 和 pika 1.1.0 从 RabbitMQ 3.7.12 消费。

Answer 1

使用超时的“消费生成器” 。

---

_{注意： RabbitMQ 团队会监控rabbitmq-users 邮件列表，有时只会在 StackOverflow 上回答问题。}