Consuming messages in RabbitMQ - Mini Project: Build & Apply

Consuming Messages from RabbitMQ Queue

📖 Scenario: You are working with RabbitMQ, a message broker that helps different parts of an application talk to each other by sending messages. Your task is to write a simple Python program that connects to RabbitMQ and consumes messages from a queue.

🎯 Goal: Build a Python script that connects to a RabbitMQ server, listens to a queue named task_queue, and prints out each message it receives.

📋 What You'll Learn

Create a connection to RabbitMQ server using pika.BlockingConnection

Declare a queue named task_queue

Consume messages from task_queue using a callback function

Print each message body when received

💡 Why This Matters

🌍 Real World

Many applications use RabbitMQ to send tasks or data between services. Consuming messages lets your program react to events or process jobs asynchronously.

💼 Career

Understanding how to consume messages from RabbitMQ is a key skill for DevOps engineers and backend developers working with distributed systems and microservices.

1

Setup RabbitMQ connection and channel

Import pika and create a connection to RabbitMQ server on localhost. Then create a channel from this connection and declare a queue named task_queue.

RabbitMQ

import pika

# Your code here

Need a hint?

Use pika.BlockingConnection with pika.ConnectionParameters('localhost') to connect. Then call channel.queue_declare with the queue name.

2

Define a callback function to process messages

Define a function called callback that takes ch, method, properties, and body as parameters. Inside the function, print the message body decoded as UTF-8.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue')

def callback(ch, method, properties, body):
    # Your code here

Need a hint?

The body parameter contains the message bytes. Use body.decode('utf-8') to convert it to a string before printing.

3

Start consuming messages from the queue

Use channel.basic_consume to consume messages from task_queue using the callback function. Set auto_ack=True to automatically acknowledge messages.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue')

def callback(ch, method, properties, body):
    print(f"Received {body.decode('utf-8')}")

# Start consuming messages
# Your code here

Need a hint?

Use channel.basic_consume with the queue name, callback function, and auto_ack=True.

4

Start the message consuming loop

Call channel.start_consuming() to begin waiting for messages and processing them with the callback.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue')

def callback(ch, method, properties, body):
    print(f"Received {body.decode('utf-8')}")

channel.basic_consume(queue='task_queue', on_message_callback=callback, auto_ack=True)

# Start consuming messages
# Your code here

Need a hint?

This call keeps the program running and listening for messages until you stop it.