У меня есть BlockingConnection, и я следую примерам документации pika. Но во всех них примерами кода для начала потребления сообщений являются:
connection = pika.BlockingConnection()
channel = connection.channel()
channel.basic_consume('test', on_message)
try:
channel.start_consuming()
except KeyboardInterrupt:
channel.stop_consuming()
connection.close()
(с более или менее подробной информацией).
Мне нужно написать много скриптов, и я хочу запускать их один за другим (в целях тестирования/исследования). Но приведенный выше код требует, чтобы я добавил ^C в каждый из них.
Я пытаюсь добавить некоторые тайм-ауты, объясненные в документации, но Мне не повезло. Например, если я найду параметр для установки, если клиент не использует никаких сообщений за последние X секунд, то сценарий завершится. Возможно ли это в pika lib? или я должен изменить подход?
