redis_streams_xadd_xread_quickstart_example.py

1import redis
2
3# Connect to Redis
4r = redis.Redis(host='localhost', port=6379, decode_responses=True)
5
6# 1. Add a message to the stream 'mystream'
7# XADD returns the generated ID (e.g., '1626432421523-0')
8stream_id = r.xadd('mystream', {'sensor-id': '1234', 'temperature': '19.8'})
9print(f"Added message with ID: {stream_id}")
10
11# 2. Add another message
12r.xadd('mystream', {'sensor-id': '9999', 'temperature': '21.5'})
13
14# 3. Read messages from the beginning of the stream
15# '0' indicates reading from the start of the stream
16messages = r.xread({'mystream': '0'}, count=5)
17
18for stream_name, content in messages:
19    print(f"Stream: {stream_name}")
20    for message_id, data in content:
21        print(f"  ID: {message_id}, Data: {data}")