SUBSCRIBE to channels in Redis - Mini Project: Build & Apply

Subscribe to Redis Channels

📖 Scenario: You are building a simple notification system where users can subscribe to different topics (channels) to receive updates in real-time.

🎯 Goal: Create a Redis subscription setup where a client subscribes to specific channels to listen for messages.

📋 What You'll Learn

Create a Redis client connection

Subscribe to the channels named 'news' and 'sports'

Implement a message handler to process incoming messages

Ensure the subscription listens continuously for messages

💡 Why This Matters

🌍 Real World

Real-time notification systems use Redis subscriptions to deliver updates instantly to users, such as news alerts or sports scores.

💼 Career

Understanding Redis PubSub is valuable for backend developers working on scalable messaging and event-driven applications.

1

Create Redis client connection

Create a Redis client connection using the variable client.

Redis

# Your code here to create Redis client connection named client

Need a hint?

Use redis.Redis() to create a client connection.

2

Subscribe to channels

Create a PubSub object called pubsub from client and subscribe to the channels 'news' and 'sports'.

Redis

client = redis.Redis()
# Your code here to create pubsub and subscribe to 'news' and 'sports'

Need a hint?

Use client.pubsub() to create the PubSub object and subscribe() method with channel names.

3

Implement message handler loop

Use a for loop to iterate over pubsub.listen() and assign each message to the variable message.

Redis

client = redis.Redis()
pubsub = client.pubsub()
pubsub.subscribe('news', 'sports')
# Your code here to loop over pubsub.listen() with variable message

Need a hint?

Use for message in pubsub.listen(): to continuously listen for messages.

4

Process received messages

Inside the for loop, add an if statement to check if message['type'] == 'message' and then assign message['data'] to a variable called data.

Redis

client = redis.Redis()
pubsub = client.pubsub()
pubsub.subscribe('news', 'sports')
for message in pubsub.listen():
    # Your code here to check message type and assign data

Need a hint?

Check the message type before processing and assign the message content to data.