Build Microservices Web Apps with RabbitMQ, React TSX, and Django/

...

/

Creating a RabbitMQ Producer for the Core App

Creating a RabbitMQ Producer for the Core App

Learn how to create a RabbitMQ producer in Flask.

We'll cover the following...

Now that we have our request routes, let’s create a RabbitMQ producer for the Core app.

Creating a producer in the Core app

To create a RabbitMQ producer in the Core app, we'll create a file in the backendservice2 app directory folder named producer.py. Then, we'll open the file and import pika and json, as follows:

import pika, json

We can use pika to create a connection and define a publish function to publish our messages, as shown below:

Python
import pika, json
params = pika.URLParameters('{{Your_AMQP_URL}}')
connection = pika.BlockingConnection(params)
channel = connection.channel()
def publish(method, body):
    properties = pika.BasicProperties(method)
    channel.basic_publish(exchange='', routing_key='config', body=json.dumps(body), properties=properties)

  • Line 4: We create a variable, params, which is set to ...