AMQP_producer_many.py

#!/usr/bin/env python3
""" If script executed with arguments, all of them will be send over AMQP
to reciver:

    $ python producer.py -n <number of messages>

From: https://radeksm.github.io/2019/07/01/RabbitMQ_crash_course2.html
"""
import argparse
import pika
import os

QNAME='queue0'
RABBIT_PORT = 5672
RABBIT_IP = os.environ.get("RABBIT_IP", None)

def message(seq_number=0):
    _msg = "AMQP MESSAGE {:d}".format(seq_number)
    return _msg

def main():
    if RABBIT_IP is None:
        print("Missing RABBIT_IP env variable")

    parser = argparse.ArgumentParser(description='Send some AMQP messages')
    parser.add_argument('-n', type=int,
                        help="Number of messages to send")
    args = parser.parse_args()

    msg = message()
    print('AMQP producer connecting to {}:{} with message: \"{}\"'.\
          format(RABBIT_IP, RABBIT_PORT, msg))
    connection = pika.BlockingConnection(pika.ConnectionParameters(RABBIT_IP, RABBIT_PORT))
    channel = connection.channel()
    channel.queue_declare(queue=QNAME)

    for x in range(0,args.n):
        channel.basic_publish(exchange='',
                              routing_key=QNAME,
                              body=message(x))
    connection.close()

if __name__ == '__main__':
    main()