Stream

XGROUP CREATE

Create a new consumer group for a Redis stream.

Arguments

keybodystrrequired

The key of the stream.

groupbodystrrequired

The consumer group name.

idbodystrrequired

The stream entry ID to start consuming from. Use '$' to start from the end.

mkstreambodybool

Create the stream if it doesn't exist.

Response

str

Returns "OK" if the consumer group was created successfully.

Start from end
result = redis.xgroup_create("mystream", "mygroup", "$")
Create stream if not exists
result = redis.xgroup_create("newstream", "mygroup", "$", mkstream=True)
Start from beginning
result = redis.xgroup_create("mystream", "mygroup2", "0-0")
Loading search…