XINFO STREAM

语法
XINFO STREAM key [FULL [COUNT count]]
可用自
5.0.0
时间复杂度
O(1)
ACL 类别
@read, @stream, @slow,

此命令返回存储在 <key> 中的流的信息。

此命令提供的详细信息包括

  • 长度：流中条目的数量（参见 XLEN）
  • 基数树键：底层基数数据结构中的键数量
  • 基数树节点：底层基数数据结构中的节点数量
  • 组：为流定义的消费者组数量
  • 最后生成的 ID：添加到流中的最新条目的 ID
  • 最大删除条目 ID：从流中删除的最大条目 ID
  • 添加的条目：流在其生命周期内添加的所有条目的计数
  • 第一个条目：流中第一个条目的 ID 和字段值元组
  • 最后一个条目：流中最后一个条目的 ID 和字段值元组

FULL 修饰符

可选的 FULL 修饰符提供更详细的回复。当提供时，FULL 回复包含一个 条目 数组，该数组由流条目（ID 和字段值元组）组成，按升序排列。此外，组 也是一个数组，对于每个消费者组，它包含由 XINFO GROUPS 和 XINFO CONSUMERS 报告的信息。

为每个组提供以下信息

  • 名称：消费者组的名称
  • 最后交付的 ID：最后交付给组消费者条目的 ID
  • 已读取的条目：最后交付给组消费者的条目的逻辑“读取计数器”
  • 延迟：流中仍在等待交付给组消费者的条目数量，或者当该数量无法确定时为 NULL。
  • pel 计数：组的挂起条目列表 (PEL) 的长度，即已交付但尚未确认的消息
  • 挂起：包含挂起条目信息的数组（见下文）
  • 消费者：包含消费者信息的数组（见下文）

为每个挂起条目提供以下信息

  1. 消息的 ID。
  2. 获取消息并仍需确认的消费者的名称。我们称之为消息的当前所有者。
  3. 向该消费者交付消息时的 UNIX 时间戳。
  4. 此消息交付的次数。

为每个消费者提供以下信息

  • 名称：消费者的名称
  • 已见时间：最后一次尝试交互的 UNIX 时间戳（例如：XREADGROUP、XCLAIM、XAUTOCLAIM）
  • 活跃时间：最后一次成功交互的 UNIX 时间戳（例如：XREADGROUP 实际上将一些条目读入 PEL，XCLAIM/XAUTOCLAIM 实际上声明了一些条目）
  • pel 计数：PEL 中的条目数量：消费者的挂起消息，即已交付但尚未确认的消息
  • 挂起：包含挂起条目信息的数组，结构与上面描述的相同，除了消费者名称被省略（冗余，因为无论如何我们都处于特定消费者上下文中）

请注意，在 Redis 7.2.0 之前，已见时间 用于表示最后一次成功交互。在 7.2.0 中，添加了 活跃时间，并将 已见时间 更改为表示最后一次尝试交互。

COUNT 选项可用于限制返回的流和 PEL 条目的数量（将返回前 <count> 个条目）。默认的 COUNT 为 10，COUNT 为 0 表示将返回所有条目（如果流包含大量条目，则执行时间可能会很长）。

示例

默认回复

> XINFO STREAM mystream
 1) "length"
 2) (integer) 2
 3) "radix-tree-keys"
 4) (integer) 1
 5) "radix-tree-nodes"
 6) (integer) 2
 7) "last-generated-id"
 8) "1638125141232-0"
 9) "max-deleted-entry-id"
10) "0-0"
11) "entries-added"
12) (integer) 2
13) "recorded-first-entry-id"
14) "1719505260513-0"
15) "groups"
16) (integer) 1
17) "first-entry"
18) 1) "1638125133432-0"
    2) 1) "message"
       2) "apple"
19) "last-entry"
20) 1) "1638125141232-0"
    2) 1) "message"
       2) "banana"

完整回复

> XADD mystream * foo bar
"1638125133432-0"
> XADD mystream * foo bar2
"1638125141232-0"
> XGROUP CREATE mystream mygroup 0-0
OK
> XREADGROUP GROUP mygroup Alice COUNT 1 STREAMS mystream >
1) 1) "mystream"
   2) 1) 1) "1638125133432-0"
         2) 1) "foo"
            2) "bar"
> XINFO STREAM mystream FULL
 1) "length"
 2) (integer) 2
 3) "radix-tree-keys"
 4) (integer) 1
 5) "radix-tree-nodes"
 6) (integer) 2
 7) "last-generated-id"
 8) "1638125141232-0"
 9) "max-deleted-entry-id"
10) "0-0"
11) "entries-added"
12) (integer) 2
13) "recorded-first-entry-id"
14) "1719505260513-0"
15) "entries"
16) 1) 1) "1638125133432-0"
       2) 1) "foo"
          2) "bar"
    2) 1) "1638125141232-0"
       2) 1) "foo"
          2) "bar2"
17) "groups"
18) 1)  1) "name"
        2) "mygroup"
        3) "last-delivered-id"
        4) "1638125133432-0"
        5) "entries-read"
        6) (integer) 1
        7) "lag"
        8) (integer) 1
        9) "pel-count"
       10) (integer) 1
       11) "pending"
       12) 1) 1) "1638125133432-0"
              2) "Alice"
              3) (integer) 1638125153423
              4) (integer) 1
       13) "consumers"
       14) 1) 1) "name"
              2) "Alice"
              3) "seen-time"
              4) (integer) 1638125133422
              5) "active-time"
              6) (integer) 1638125133432
              7) "pel-count"
              8) (integer) 1
              9) "pending"
              10) 1) 1) "1638125133432-0"
                     2) (integer) 1638125133432
                     3) (integer) 1

RESP2 回复

以下之一

  • 数组回复：当使用 FULL 参数时，将返回有关流的摘要信息列表。
  • 数组回复：当使用 FULL 参数时，将返回有关流的扩展信息列表。

RESP3 回复

以下之一

  • 映射回复：当未给出 FULL 参数时，将返回有关流的摘要信息列表。
  • 映射回复：当给出 FULL 参数时，将返回有关流的扩展信息列表。

历史

  • 从 Redis 6.0.0 版本开始：添加了 FULL 修饰符。
  • 从 Redis 7.0.0 版本开始：添加了 max-deleted-entry-id、entries-added、recorded-first-entry-id、entries-read 和 lag 字段。
  • 从 Redis 7.2.0 版本开始：添加了 active-time 字段，并更改了 seen-time 的含义。
RATE THIS PAGE
Back to top ↑