kombu 这套货色,到底是在哪里建设 amqp 连贯的
from kombu import Connectionfrom kombu.pools import connectionsconnection = Connection('redis://localhost:6379')with connections[connection].acquire(block=True) as conn: print('Got connection: {0!r}'.format(connection.as_uri()))办法：人肉看代码，手动二分，加 wireshark 抓包
在这里加了一个断言site-packages/kombu/transport/pyamqp.py
╰─➤ python 001.py Traceback (most recent call last): File "/Users/ponponon/Desktop/code/me/test_nameko_for_rabbitmq/001.py", line 11, in <module> conn.connect() File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py", line 274, in connect c=self._ensure_connection( File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py", line 436, in _ensure_connection return retry_over_time( File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/utils/functional.py", line 312, in retry_over_time return fun(*args, **kwargs) File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py", line 880, in _connection_factory self._connection = self._establish_connection() File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/connection.py", line 815, in _establish_connection conn = self.transport.establish_connection() File "/Users/ponponon/.local/share/virtualenvs/test_nameko_for_rabbitmq-Kw9_vVsf/lib/python3.10/site-packages/kombu/transport/pyamqp.py", line 199, in establish_connection assert FalseAssertionError