Pika BlockingConnection & RabbitMQ: соединение закрыто ⇐ Python

[Anonymous]

У меня есть 2 RabbitMQ в кластере, балансирующая нагрузку с помощью внутреннего балансировщика нагрузки Azure. Клиент подключается к LB с помощью BlockingConnection.

Когда клиенты обмениваются сообщениями, все работает нормально. Но когда нет активности, кажется, что мои клиенты отключены и больше не могут получать сообщения.

Мне интересно, есть ли решение этой проблемы? Я предполагаю, что балансировщик нагрузки или RabbitMQ закрывает соединение из-за бездействия. Я хотел позволить pika инициировать контрольное сообщение для RabbitMQ (чтобы балансировщик нагрузки сохранял соединение открытым), но не нашел хорошего решения. Не могли бы вы посоветовать?

EDIT 1
Кажется, pika BlockingConnections не поддерживает пульс. Heartbeat отключает блокировку соединения

Спасибо.

Подробнее здесь: https://stackoverflow.com/questions/347 ... ion-closed