Pasted

#!/bin/env python3
 
# docker exec -it rabbit0  /usr/lib/rabbitmq/bin/rabbitmqctl status
# docker exec -it rabbit0  rabbitmqctl list_queues
# docker exec -it rabbit0  rabbitmqctl list_vhosts
# docker exec -it rabbit0  rabbitmqctl list_connections
 
import pika
import os
 
RABBIT_IP = os.environ["RABBIT_IP"]
RABBIT_PORT = 5672
QNAME='queue0'
 
def main():
    print('AMQP producer connecting to {}:{}'.format(RABBIT_IP, RABBIT_PORT))
    connection = pika.BlockingConnection(pika.ConnectionParameters(RABBIT_IP, RABBIT_PORT))
    channel = connection.channel()
    channel.queue_declare(queue=QNAME)
    channel.basic_publish(exchange='',
        routing_key=QNAME,
        body='Hello World!')
    connection.close()
 
if __name__ == '__main__':
    main()