Используя pika.BlockingConnection, я хотел бы получить сообщения из очереди, а затем выйти

Question

Я написал получателя с помощью pika.BlockingConnection и channel.start_consuming (), который потребляет сообщения из определенной очереди. Когда сообщения исчерпываются из очереди, получатель ожидает в течение неопределенного времени следующего сообщения.

Есть ли способ, которым я мог бы указать какую-то продолжительность тайм-аута, по которой start_consuming () будет корректно завершать работу, если потребитель не получит сообщение из очереди в течение определенного периода времени.

Я использую Python 3.7.4 и пика 1.1.0 для потребления из RabbitMQ 3.7.12.

Answer 1

Используйте «генератор потребления» с тайм-аутом.

---

_{ПРИМЕЧАНИЕ: команда RabbitMQ контролирует rabbitmq-users список рассылки и только иногда отвечает на вопросы по StackOverflow.}