python – How to send messages from Flask server to RabbitMQ server queue?

I’m trying to send a message from Flask server, which acts as a producer, to a RabbitMQ server queue. The port I’m using to produce the messages is ‘5672’.

I’ve created an exchange and a queue on RabbitMQ’s Management server and the main goal is to receive a message in the server’s queue.

This is the code that I have at the moment, it does not produce any errors and returns that the message has been sent:

@app.route("/create/<message>")
def create_bucket(message):
    credentials = pika.PlainCredentials("guest", "guest")
    connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost", credentials=credentials))
    channel = connection.channel()
    channel.queue_declare(queue="TestQueue", durable=True)
    channel.basic_publish(exchange="TestExchange", routing_key="TestQueue", body=message, properties=pika.BasicProperties(delivery_mode=2))
    connection.close()
    return "[x] Message sent %s" % message 

if __name__ == "__main__":
    app.run(debug=True, port=5672)

Though the message does not appear in RabbitMQ’s server’s queue.

Are there any resources or ways to send a message from Flask’s server to RabbitMQ’s server queue?

Read more here: Source link