redis_pubsub_subscribe_publish_listen_quickstart.py

1import redis
2
3# Connect to Redis
4r = redis.Redis(host='localhost', port=6379, db=0, decode_responses=True)
5
6# Create a pubsub object
7p = r.pubsub()
8
9# Subscribe to a channel
10p.subscribe('my-channel')
11
12# Publish a message to the channel
13r.publish('my-channel', 'hello world')
14
15# Listen for messages
16for message in p.listen():
17    if message['type'] == 'message':
18        print(f"Received: {message['data']}")
19        break  # Exit after receiving the first message for this example