监控状态

Flux 帮助您监控指标和事件中的状态

• 查找状态持续多长时间
• 计算连续状态的数量

如果您刚开始使用 Flux 查询，请查看以下内容

• Flux 入门，了解 Flux 的概念概述。
• 执行查询，了解运行查询的各种方法。

查找状态持续多长时间

使用 stateDuration() 计算具有指定状态的连续行的持续时间。对于每个与指定状态匹配的连续点，stateDuration() 会递增并将持续时间（以指定的单位）存储在用户定义的列中。

包括以下信息

• 要搜索的列： 任何标签键、标签值、字段键、字段值或测量值。
• 值： 要在指定列中搜索的值（或状态）。
• 状态持续时间列： 用于存储状态持续时间的新列——指定值持续的时间长度。
• 单位： 用于递增状态持续时间的时间单位（1s（默认）、1m、1h）。

data
    |> stateDuration(fn: (r) => r.column_to_search == "value_to_search_for", column: "state_duration", unit: 1s)

• 对于第一个评估为 true 的点，状态持续时间设置为 0。对于每个评估为 true 的连续点，状态持续时间将增加每个连续点之间的时间间隔（以指定单位）。
• 如果状态为 false，则状态持续时间将重置为 -1。

使用 stateDuration() 的示例查询

以下查询在过去 5 分钟内搜索 doors 存储桶，以查找门 closed 了多少秒。

from(bucket: "doors")
    |> range(start: -5m)
    |> stateDuration(fn: (r) => r._value == "closed", column: "door_closed", unit: 1s)

在此示例中，door_closed 是状态持续时间列。如果您每分钟向 doors 存储桶写入数据，则对于每个 _value 为 closed 的连续点，状态持续时间将增加 60 秒。如果 _value 不是 closed，则状态持续时间将重置为 0。

查询结果

上面示例查询的结果可能如下所示（为简单起见，我们省略了测量值、标签和字段列）

计算连续状态的数量

使用 stateCount() 函数 并包括以下信息

• 要搜索的列： 任何标签键、标签值、字段键、字段值或测量值。
• 值： 要在指定列中搜索的值。
• 状态计数列： 用于存储状态计数的新列——指定值存在的连续记录数。

|> stateCount(
    fn: (r) => r.column_to_search == "value_to_search_for",
    column: "state_count",
)

• 对于第一个评估为 true 的点，状态计数设置为 1。对于每个评估为 true 的连续点，状态计数将增加 1。
• 如果状态为 false，则状态计数将重置为 -1。

使用 stateCount() 的示例查询

以下查询在过去 5 分钟内搜索 doors 存储桶，并计算有多少个点将其 _value 设置为 closed。

from(bucket: "doors")
    |> range(start: -5m)
    |> stateCount(fn: (r) => r._value == "closed", column: "door_closed")

此示例将状态计数存储在 door_closed 列中。如果您每分钟向 doors 存储桶写入数据，则对于每个 _value 为 closed 的连续点，状态计数将增加 1。如果 _value 不是 closed，则状态计数将重置为 -1。

查询结果

上面示例查询的结果可能如下所示（为简单起见，我们省略了测量值、标签和字段列）

用于计数机器状态的示例查询

以下查询每分钟检查机器状态（空闲、已分配或忙碌）。InfluxDB 在过去一小时内搜索 servers 存储桶，并计算机器状态为 idle、assigned 或 busy 的记录。

from(bucket: "servers")
    |> range(start: -1h)
    |> filter(fn: (r) => r.machine_state == "idle" or r.machine_state == "assigned" or r.machine_state == "busy")
    |> stateCount(fn: (r) => r.machine_state == "busy", column: "_count")
    |> stateCount(fn: (r) => r.machine_state == "assigned", column: "_count")
    |> stateCount(fn: (r) => r.machine_state == "idle", column: "_count")