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

Question

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

如果消费者在特定时间段内没有从队列中获取任何消息，我是否可以指定某种超时持续时间。

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

Answer 1

使用 "consume generator" 超时。

---

_{注意：RabbitMQ 团队会监控 rabbitmq-users mailing list，并且有时只回答 StackOverflow 上的问题。}