Redis: Streams
A Redis stream is a data structure that acts like an append-only log but also implements several operations to overcome some of the limits of a typical append-only log. We can use streams to record and simultaneously syndicate events in real time.
Redis generates a unique ID for each stream entry.
Streams keep messages in Redis for as long as you want (configurable).
Consumers can read at their own pace, even if they were offline.
We can acknowledge messages (
XACK) and track delivery.
Similar like pub/sub we need A producer and consumers to implement redis streams in our system.
Basic Example
Lets create a basic example of redis streams using XADD and XREAD command.
Setup
To run redis server you can install it directly in your machine or using virtualization. For me I prefer to use docker and here is how to do it.
Run a detached container with name my-redis using latest redis image and expose the port 6379.
docker run -d -p 6379:6379 --name my-redis redisRun redis-cli inside the newly created redis container.
➜ redis_streams docker exec -it my-redis redis-cli
127.0.0.1:6379> XADD
XADDThis is the simplest form of adding a message to a Redis Stream. Each message will have a unique ID and some data fields.
127.0.0.1:6379> XADD mystream * message Hello
"1740039025432-0"mystream: name of the stream, redis will create the stream if not exist.*: Stream ID, will auto-generate a unique ID if the ID argument specified is the*.message Hello: Key value pair data,messageis the key and value isHello.
XREAD
XREADRead data from one or multiple streams. This command has an option to block if items are not available.
127.0.0.1:6379> XREAD COUNT 1 STREAMS mystream 0
1) 1) "mystream"
2) 1) 1) "1740039025432-0"
2) 1) "message"
2) "Hello"COUNT 1: Return maximum 1 element for each stream.STREAMS mystream 0:mystream: Name of the stream.0: Read element from the start.
References
Last updated