Блог

Главная - Вопросы по программированию - Ошибка подключения RabbitMQ Pika к _AsyncBaseTransport._consume()

Ошибка подключения RabbitMQ Pika к _AsyncBaseTransport._consume()

#python #rabbitmq #python-pika

#python #rabbitmq #python-pika

Вопрос:

Наблюдаемая ниже ошибка в приложении flask, использующем pika для rabbitmq,

использование pika версии 1.1.0 rabbitmq версии 3.8.5

Примечание: настроенное значение сердцебиения равно 900 (установлено более высокое значение из-за длительной работы, поэтому я должен поддерживать соединение между pika и rabbitmq)

потеря соединения происходит через некоторое время, я должен перезапустить приложение, чтобы снова подключить rabbitmq. может ли кто-нибудь указать мне правильное направление относительно того, что именно происходит не так!

 ERROR:pika.adapters.utils.io_services_utils:_AsyncBaseTransport._consume() failed, aborting connection: error=ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None); sock=<socket.socket fd=556, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('0.0.0.0', 65083), raddr=('0.0.0.0', 5672)>; Caller's stack:
Traceback (most recent call last):
  File "pikaadaptersutilsio_services_utils.py", line 1041, in _on_socket_readable
  File "pikaadaptersutilsio_services_utils.py", line 791, in _consume
  File "pikaadaptersutilsio_services_utils.py", line 79, in retry_sigint_wrap
  File "pikaadaptersutilsio_services_utils.py", line 846, in _sigint_safe_recv
ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
Traceback (most recent call last):
  File "pikaadaptersutilsio_services_utils.py", line 1041, in _on_socket_readable
  File "pikaadaptersutilsio_services_utils.py", line 791, in _consume
  File "pikaadaptersutilsio_services_utils.py", line 79, in retry_sigint_wrap
  File "pikaadaptersutilsio_services_utils.py", line 846, in _sigint_safe_recv
ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
ERROR:pika.adapters.base_connection:connection_lost: StreamLostError: ("Stream connection lost: ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None)",)
ERROR:pika.adapters.blocking_connection:Unexpected connection close detected: StreamLostError: ("Stream connection lost: ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None)",)

Комментарии:

1. У меня такая же проблема… вы это исправили? Есть ли у вас какие-либо обновления о том, как вы это сделали?