PSUBSCRIBE for pattern matching in Redis - Mini Project: Build & Apply

Using PSUBSCRIBE for Pattern Matching in Redis

📖 Scenario: You are managing a chat application where users send messages to different chat rooms. You want to listen to messages from multiple chat rooms that share a common naming pattern.

🎯 Goal: Build a Redis subscriber that uses PSUBSCRIBE to listen to all chat rooms whose names start with room:.

📋 What You'll Learn

Create a Redis channel pattern variable called pattern with the value room:*

Use the PSUBSCRIBE command with the pattern variable to subscribe to matching channels

Implement a message handler function called message_handler that takes pattern, channel, and message as parameters

Print the received channel and message inside the message_handler function

💡 Why This Matters

🌍 Real World

Pattern matching subscriptions are useful in chat apps, notifications, and event-driven systems where you want to listen to groups of related channels.

💼 Career

Understanding PSUBSCRIBE helps in building scalable real-time applications and working with Redis Pub/Sub features in backend development.

1

Set up the Redis client connection

Create a Redis client connection variable called client using redis.Redis().

Redis

# Your code here to create Redis client connection

Need a hint?

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

2

Create the channel pattern variable

Create a variable called pattern and set it to the string 'room:*' to match all channels starting with room:.

Redis

import redis

client = redis.Redis()

# Create the pattern variable for PSUBSCRIBE

Need a hint?

Use the wildcard * to match any channel name starting with room:.

3

Define the message handler function

Define a function called message_handler that takes three parameters: pattern, channel, and message. Inside the function, print the channel and message.

Redis

import redis

client = redis.Redis()

pattern = 'room:*'

# Define the message_handler function

Need a hint?

Use an f-string to print the channel and message inside the function.

4

Subscribe to channels using PSUBSCRIBE with the pattern

Use client.pubsub() to create a PubSub object called pubsub. Then use pubsub.psubscribe() with the pattern and message_handler as the callback to subscribe to matching channels.

Redis

import redis

client = redis.Redis()

pattern = 'room:*'

def message_handler(pattern, channel, message):
    print(f"Received message from {channel}: {message}")

# Create pubsub and subscribe using PSUBSCRIBE

Need a hint?

Use psubscribe with a dictionary mapping the pattern to the handler function.