RabbitMQ. Basic Publish - nagaevkirill/WIKI GitHub Wiki

import pika

creds = pika.credentials.PlainCredentials('user', 'userpass')

connection = pika.BlockingConnection(pika.ConnectionParameters('82.146.**.126', '5672', 'main', creds))
channel = connection.channel()

channel.queue_declare('dev1', durable=True, auto_delete=False)
channel.queue_bind(queue='dev1', exchange='amq.direct', routing_key='dev1')

for x in range(1, 5):
    channel.basic_publish(exchange='amq.direct',
                          routing_key='dev1',
                          body=f'Producer 1')
    # print(f" [x] Sent 'Hello World! {x}'")

connection.close()
print('DONE')

https://github.com/nagaevkirill/rabbitmq_basic_publish_consume