Search⌘ K
AI Features
Home
Courses
Build Microservices Web Apps with RabbitMQ, React TSX, and Django

Creating a RabbitMQ Producer for the Core App

Explore how to create a RabbitMQ producer in a Python-based Core app using pika. Understand connecting to an AMQP broker, defining a publish function, and routing messages to specific queues. Gain practical steps to integrate the producer with the app's core functionality for event-driven communication.

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 ...