AMQP_producer.py

#!/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()