- 用法
-
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 | 新增 |