import pika
credentials = pika.PlainCredentials(username='guest', password='guest')
connection = 'amqp://10.0.4.143'
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='10.0.5.183'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello.', body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()
Ошибка, которую я получаю, это поднять self._reap_last_connection_workflow_error (error) pika.exceptions.AMQPConnectionError