Event sourcing with RabbitMQ - Mini Project: Build & Apply

Event sourcing with RabbitMQ

📖 Scenario: You are building a simple event sourcing system using RabbitMQ. Events represent actions in your application, and you want to send these events to a queue so other services can process them later.This project will guide you through creating a queue, publishing events, and consuming them step-by-step.

🎯 Goal: Build a basic RabbitMQ setup where you create a queue named event_queue, publish event messages to it, and consume those events to print them out.

📋 What You'll Learn

Create a queue named event_queue

Publish three event messages with exact content to the queue

Consume messages from event_queue and print each event

Use RabbitMQ commands or Python pika library commands exactly as instructed

💡 Why This Matters

🌍 Real World

Event sourcing is used in real applications to record all changes as events. RabbitMQ helps by reliably sending and storing these events for later processing.

💼 Career

Understanding how to use RabbitMQ for event sourcing is valuable for roles in DevOps, backend development, and system architecture where event-driven design is common.

1

Create the RabbitMQ queue

Write the command to declare a queue named event_queue using RabbitMQ's rabbitmqadmin tool.

RabbitMQ

# Write the command to declare the queue named 'event_queue'
# Your code here

Need a hint?

Use rabbitmqadmin declare queue name=event_queue durable=true to create a durable queue.

2

Publish event messages to the queue

Write three separate commands to publish these exact messages to the event_queue queue using rabbitmqadmin: 1. {"event": "user_signed_up", "user_id": 101} 2. {"event": "order_placed", "order_id": 5001} 3. {"event": "payment_received", "payment_id": 3001}

RabbitMQ

rabbitmqadmin declare queue name=event_queue durable=true
# Publish the first event message below
# Your code here

Need a hint?

Use rabbitmqadmin publish routing_key=event_queue payload='...' for each event message.

3

Consume and print event messages

Write a command to consume messages from the event_queue queue using rabbitmqadmin and print each message to the console.

RabbitMQ

rabbitmqadmin declare queue name=event_queue durable=true
rabbitmqadmin publish routing_key=event_queue payload='{"event": "user_signed_up", "user_id": 101}'
rabbitmqadmin publish routing_key=event_queue payload='{"event": "order_placed", "order_id": 5001}'
rabbitmqadmin publish routing_key=event_queue payload='{"event": "payment_received", "payment_id": 3001}'
# Write the command to consume messages from 'event_queue'
# Your code here

Need a hint?

Use rabbitmqadmin get queue=event_queue requeue=false to consume and print messages.

4

Display the consumed event messages

Write a command or script output that shows the three event messages printed exactly as they were published, confirming they were consumed from event_queue.

RabbitMQ

rabbitmqadmin declare queue name=event_queue durable=true
rabbitmqadmin publish routing_key=event_queue payload='{"event": "user_signed_up", "user_id": 101}'
rabbitmqadmin publish routing_key=event_queue payload='{"event": "order_placed", "order_id": 5001}'
rabbitmqadmin publish routing_key=event_queue payload='{"event": "payment_received", "payment_id": 3001}'
rabbitmqadmin get queue=event_queue requeue=false
# Show the output of consumed messages here
# Your code here

Need a hint?

Run rabbitmqadmin get queue=event_queue requeue=false and check the printed payloads match the published events exactly.