当前位置: 首页 > 后端技术 > Python

Kombu的懒连接?

时间:2023-03-26 13:31:55 Python

从kombuimportConnectionfromkombu.poolsimportconnectionsconnection=Connection('redis://localhost:6379')withconnections[connection].acquire(block=True)asconn:print('Gotconnection:{0!r}'.format(connection.as_uri()))方法:手动读取代码,添加wireshark抓包,这里添加断言site-packages/kombu/transport/pyamqp.py╰─?python001.pyTraceback(最近的最后调用):文件“/Users/ponponon/Desktop/code/me/test_nameko_for_rabbitmq/001.py”,第11行,在conn.connect()文件“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py”,第274行,在connectc=self._ensure_connection(File“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py",line436,in_ensure_connectionreturnretry_over_time(文件“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/utils/functional.py”,第312行,在retry_over_timereturnfun(*args,**kwargs)文件“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py”,第880行,在_connection_factoryself._connection=self._establish_connection()文件“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py”,第815行,在_establish_connectionconn=self.transport.establish_connection()文件中“/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/transport/pyamqp.py”,第199行,在establish_connection断言FalseAssertionError