Saga pattern for distributed transactions in RabbitMQ - Mini Project: Build & Apply

Saga Pattern for Distributed Transactions with RabbitMQ

📖 Scenario: You are building a simple order processing system that uses the Saga pattern to manage distributed transactions across multiple services. Each service communicates through RabbitMQ messages to ensure data consistency even if some steps fail.This project simulates three services: Order Service, Payment Service, and Inventory Service. Each service sends and listens to messages to complete or compensate transactions.

🎯 Goal: Build a basic Python script that demonstrates the Saga pattern using RabbitMQ. You will create a message queue setup, define transaction steps, and implement compensation logic to rollback if any step fails.

📋 What You'll Learn

Create a dictionary called services with keys 'order', 'payment', and 'inventory' and their initial statuses set to 'pending'.

Add a variable called compensation_needed and set it to false.

Write a for loop that iterates over services.items() and sets each service status to 'completed' unless compensation_needed is true, in which case set the status to 'compensated' and break the loop.

Print the final services dictionary to show the transaction result.

💡 Why This Matters

🌍 Real World

The Saga pattern helps keep data consistent across multiple services in real-world systems like e-commerce, banking, and booking platforms where transactions span many components.

💼 Career

Understanding and implementing the Saga pattern is important for DevOps engineers and backend developers working with microservices and distributed systems to ensure reliable and fault-tolerant workflows.

1

Create initial service statuses

Create a dictionary called services with keys 'order', 'payment', and 'inventory' each set to the string 'pending'.

RabbitMQ

# Create the services dictionary with initial statuses
# Your code here

Need a hint?

Use a dictionary with the exact keys and values as specified.

2

Add compensation flag

Add a variable called compensation_needed and set it to false.

RabbitMQ

services = {'order': 'pending', 'payment': 'pending', 'inventory': 'pending'}
# Add the compensation_needed flag
# Your code here

Need a hint?

Just create a boolean variable named exactly compensation_needed.

3

Implement saga transaction logic

Write a for loop using service, status in services.items() that sets each service's status to 'completed' if compensation_needed is false. If compensation_needed is true, set the current service's status to 'compensated' and break the loop.

RabbitMQ

services = {'order': 'pending', 'payment': 'pending', 'inventory': 'pending'}
compensation_needed = false
# Implement the saga transaction loop
# Your code here

Need a hint?

Use the exact variable names and conditions as described.

4

Display final transaction status

Write a print statement to display the services dictionary showing the final statuses after the saga transaction.

RabbitMQ

services = {'order': 'pending', 'payment': 'pending', 'inventory': 'pending'}
compensation_needed = false
for service, status in services.items():
    if not compensation_needed:
        services[service] = 'completed'
    else:
        services[service] = 'compensated'
        break
# Print the final services dictionary
# Your code here

Need a hint?

Use print(services) exactly to show the final dictionary.