XGROUP CREATE

XGROUP CREATE key group <id | $> [MKSTREAM]
  [ENTRIESREAD entries-read]

自版本起可用

5.0.0

时间复杂度

O(1)

ACL 类别

@write, @stream, @slow,

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

每个组在给定流中都有唯一的名称。当存在相同名称的消费者组时，命令将返回 -BUSYGROUP 错误。

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

例如，如果您希望组的消费者从头开始获取整个流，请将零用作消费者组的起始 ID

XGROUP CREATE mystream mygroup 0

默认情况下，XGROUP CREATE 命令期望目标流存在，并在不存在时返回错误。如果流不存在，您可以使用可选的 MKSTREAM 子命令作为 <id> 后的最后一个参数，自动创建它，长度为 0。

XGROUP CREATE mystream mygroup $ MKSTREAM

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

RESP2/RESP3 响应

历史

• 从 Redis 版本 7.0.0 开始：添加了 entries_read 命名参数。