Creating a RabbitMQ Consumer for the Houses App
Explore how to build a RabbitMQ consumer for the Django Houses app by setting up the environment, connecting to a message broker, defining callback functions, and processing messages to update house data. Understand the use of pika, message acknowledgment, and interaction with the Django ORM in a microservices context.
We'll cover the following...
Creating a consumer for the Config and Houses apps
In RabbitMQ, the word consumer refers to any application or program that receives messages. Therefore, consuming means receiving.
To create a RabbitMQ consumer for the Config and Houses app, we'll create a file in the backendservice1 app directory named consumer.py. Then, we open the file and import os, django, pika, and json, as follows:
import os, django, pika, json
We also have to set up our OS environment and Django:
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings")
django.setup()
We then import our House model from the models.py file in the houses app, but only after calling the django.setup():
from houses.models import