我已经用python编写了redis stream consumer
,minimal code
看起来如下:
key = 'order_completed'
group = 'inventory_group'
redis.xgroup_create(key, group) #statement1
result = redis.xreadgroup(group, key, {key: '>'}, None) #statement2
我需要帮助来理解最后两个语句。
我有限的理解是redis.xgroup_create(key, group)
正在创建consumer group.
并且,redis.xreadgroup(group, key, {key: '>'}, None)
用于读取流中的最新条目。
什么是{key: '>'}
?
我已经阅读了xreadgroup,但无法从中理解太多。
1条答案
按热度按时间rggaifut1#
>
特殊流条目ID使XREADGROUP只返回从未传递给组中任何用户的流条目-基本上,它将只返回新条目。除了
>
之外,该命令还接受任何其他常规流条目ID:在这种情况下,XREADGROUP会传回已经传送给呼叫消费者的数据流项目,其ID大于传递的值。从command documentation:
当使用XREADGROUP时,要在STREAMS选项中指定的ID可以是以下两个ID之一: