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

...

/

Creating a RabbitMQ Producer for the Houses App

Creating a RabbitMQ Producer for the Houses App

Learn how to create a RabbitMQ producer in Django.

We'll cover the following...

Creating a producer in the Houses app

In RabbitMQ, the word producer refers to any application or program that sends messages. Therefore, producing means sending.

To create a RabbitMQ producer in the Houses app, we'll create a file in the houses app folder named producer.py. We'll use Pika, a Python implementation of the AMQP 0-9-1 protocol for RabbitMQ, to connect our web application to RabbitMQ.

Then, we'll open the file and import pika and json, like so:

import pika, json

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

Press + to interact
Please provide values for the following:
Your_AMQP_URL
Not Specified...
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='core', body=json.dumps(body), properties=properties)
    ...