大家好,我正在使用下面的代码块来创建一个异步连接。我只是想创建一个异步连接,并创建一个通道。我正在与pika版本:1.2.1
URL = "http://guest:guest@0.0.0.0:15672"
connection = pika.SelectConnection(
pika.URLParameters(URL)
)
nonBlockingChan = connection.channel()
当我调用channel()时,我得到以下错误,
pika.异常.连接状态错误错误:通道分配需要打开连接:- 〈选择连接INIT传输=无参数=〉
服务器在本地正确运行,我可以打开rabbitMQ webUI。有人能帮助我解决这个问题吗?找到下面的rabbitMQ webUI的屏幕截图。
1条答案
按热度按时间sqougxex1#
请参阅完整示例:
https://github.com/pika/pika/tree/main/examples
https://github.com/pika/pika/blob/main/examples/asynchronous_consumer_example.py
https://github.com/pika/pika/blob/main/examples/asynchronous_publisher_example.py
**注意:**RabbitMQ团队监控
rabbitmq-users
邮件列表,仅在某些时候回答StackOverflow上的问题。