Ошибка сервера:
, но когда я использую pika для подключения к серверу rabbitmq с таким же параметром, как имя пользователя ， пароль Виртуальный хост, Пика может подключиться к серверу. ошибочный код:
транспорт, протокол = await aioamqp.connect (host = 'localhost', virtualhost = '/', port = 5672, ssl = False, insist = True, login_method = 'AMQPLAIN') # использовать параметры по умолчанию
Как я могу это решить?
Я исправил ошибку, и решение приведено ниже: 1 \ основной код ветки не соответствовал коду aioamqp pypy. 2 \ итак, я git клонировал код ветки master в свой проект и провел для него тест, а затем id мне помог.