XGROUP CREATE

用法
XGROUP CREATE key group 〈 id | $ 〉 [ MKSTREAM ] [ ENTRIESREAD entriesread ]
复杂度
O(1)
5.0.0
ACL 类别
@stream, @write, @slow

为存储在 <key> 的流创建一个由 <groupname> 唯一标识的新消费者组

每个组在给定流中都有一个唯一的名称。如果同名消费者组已存在,则命令返回 -BUSYGROUP 错误。

命令的 <id> 参数指定了从新组的角度来看,流中最后一条已传递的条目。特殊 ID $ 是流中最后一条条目的 ID,但你可以用任何有效的 ID 替换它。

例如,如果你希望该组的消费者从头开始获取整个流,请使用零作为消费者组的起始 ID

XGROUP CREATE mystream mygroup 0

默认情况下,XGROUP CREATE 命令要求目标流存在,如果不存在则返回错误。如果流不存在,你可以通过在 <id> 之后使用可选的 MKSTREAM 子命令作为最后一个参数,自动创建一个长度为 0 的流。

XGROUP CREATE mystream mygroup $ MKSTREAM

为了启用消费者组的滞后跟踪,请使用任意 ID 指定可选的 entries_read 命名参数。任意 ID 是指不是流的第一个条目、最后一个条目或零(“0-0”)ID 的任何 ID。使用它来查找任意 ID(不包括它)和流的最后一个条目之间有多少条目。将 entries_read 设置为流的 entries_added 减去条目数。

RESP2/RESP3 回复

简单字符串回复OK

历史

版本 变更
7.0.0

新增 entries_read 命名参数。