kombu/librabbitmq: ошибка соединения: не удалось восстановить канал

  1. Я использую группу пулов производителей для публикации сообщения на rabbitmq, но вызов публикации завершается ошибкой со следующей ошибкой:

,

    File "pubsub.py", line 314, in _publish
        producer.publish(message, exchange=exchange, routing_key=topic)
    File "/opt/ENV/local/lib/python2.7/site-packages/kombu/messaging.py", line 172, in publish routing_key, 
        mandatory, immediate, exchange, declare)
    File "/opt/ENV/local/lib/python2.7/site-packages/kombu/messaging.py", line 188, in _publish 
        mandatory=mandatory, immediate=immediate,
    File "/opt/local/lib/python2.7/site-packages/librabbitmq/__init__.py", line 117, in basic_publish
    mandatory or False, immediate or False,
    ConnectionError: Couldn't revive channel
  1. странная часть в том, что сообщение, предшествующее этому, для которого я получаю эту ошибку, не достигает конечного потребителя. Я использую transport_options={'verify_publish': True} в объекте Connection, который передается в пул производителей.

  2. Сервер rabbitmq находится за ELB на AWS.

Любая идея об этой ошибке выше и почему сообщения могут быть потеряны?

Благодарю.

0 ответов

Другие вопросы по тегам