- プロデューサー プール グループを使用して 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
奇妙な部分は、このエラーが発生したこのメッセージの前のメッセージが消費者側に到達していないことです。プロデューサー プールに渡される Connection オブジェクトで transport_options={'confirm_publish': True} を使用しています。
rabbitmq サーバーは、AWS の ELB の背後にあります。
上記のこのエラーと、メッセージが失われる理由について何か考えはありますか?
ありがとう。