我有以下带有asyncio和iohttp的应用程序。在应用程序启动时,我启动web界面(iohttp)和aioèu pika消费者。到目前为止,对我来说一切都正常唯一的一点是robut连接没有尝试重新连接。重新启动rabbit docker映像时,会收到以下日志消息:
[2019-11-21 14:05:13,069] INFO: Connection to amqp://guest:******@127.0.0.1/ closed. Reconnecting after 5 seconds.
但是我收到以下异常,并且它没有重新连接:
File "/usr/lib64/python3.7/asyncio/selector_events.py", line 804, in _read_ready__data_received
data = self._sock.recv(self.max_size)
ConnectionResetError: [Errno 104] Connection reset by peer
Traceback (most recent call last):
File "/home/ghovat/.local/share/virtualenvs/zendesk-wrapper-BdIlfSJk/lib/python3.7/site-packages/aio_pika/robust_connection.py", line 148, in reconnect
await self.connect()
File "/home/ghovat/.local/share/virtualenvs/zendesk-wrapper-BdIlfSJk/lib/python3.7/site-packages/aio_pika/robust_connection.py", line 134, in connect
await self.__cleanup_connection(e)
File "/home/ghovat/.local/share/virtualenvs/zendesk-wrapper-BdIlfSJk/lib/python3.7/site-packages/aio_pika/robust_connection.py", line 96, in __cleanup_connection
self.connection.close(exc),
AttributeError: 'NoneType' object has no attribute 'close'
健壮连接是否应该不再尝试重新连接?connection reset by peer
的问题似乎是兔子启动需要几秒钟。你知道吗
以下是启动应用程序的方式:
def loop_in_thread(loop):
asyncio.set_event_loop(loop)
connection = loop.run_until_complete(main(loop))
try:
loop.run_forever()
finally:
loop.run_until_complete(connection.close())
if __name__ == "__main__":
app = setup_app()
loop = asyncio.new_event_loop()
t = threading.Thread(target=loop_in_thread, args=(loop,))
t.start()
web.run_app(app)
这就是我的消费者的样子:
async def main(loop):
connection = await aio_pika.connect_robust(
"amqp://guest:guest@127.0.0.1/", loop=loop
)
queue_name = "test_queue"
print("jdklasjkl")
async with connection:
# Creating channel
channel = await connection.channel()
# Declaring queue
queue = await channel.declare_queue(
queue_name, auto_delete=False
)
async with queue.iterator() as queue_iter:
async for message in queue_iter:
async with message.process():
print(message.body)
if queue.name in message.body.decode():
break
请确保更新版本6.4.1,此pr应修复此问题-https://github.com/mosquito/aio-pika/pull/267
相关问题 更多 >
编程相关推荐