#python-3.x #rabbitmq #pika
Вопрос:
Я пытаюсь подключиться к другому хосту и получаю сообщение об ошибке
connection = pika.BlockingConnection( File "/usr/local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 360, in __init__ self._impl = self._create_connection(parameters, _impl_class) File "/usr/local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection raise self._reap_last_connection_workflow_error(error) pika.exceptions.AMQPConnectionError Мой код подключения:
credentials = pika.PlainCredentials('****', '****') connection = pika.BlockingConnection( pika.ConnectionParameters(host='localhost', virtual_host='qa1', credentials=credentials)) channel = connection.channel() channel.exchange_declare(exchange='customer_exchange3', exchange_type='fanout') Я создал qa1 vhost уже в интерфейсе управления rabbitmq.