监控状态

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

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

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

• 开始使用 Flux 以获得 Flux 的概念概述。
• 执行查询 以发现运行查询的各种方法。

查找状态持续多长时间

1. 使用 stateDuration() 函数来计算列值保持相同值（或状态）的时间。包括以下信息

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

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

2. 使用 stateDuration() 搜索每个点以查找指定值

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

使用 stateDuration() 的示例查询

以下查询在过去 5 分钟内搜索 doors bucket，以查找门已 closed 多少秒。

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

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

查询结果

上述示例查询的结果可能如下所示（为简单起见，我们省略了 measurement、tag 和 field 列）

_time                   _value        door_closed
2019-10-26T17:39:16Z    closed        0
2019-10-26T17:40:16Z    closed        60
2019-10-26T17:41:16Z    closed        120
2019-10-26T17:42:16Z    open          -1
2019-10-26T17:43:16Z    closed        0
2019-10-26T17:44:27Z    closed        60

计算连续状态的数量

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

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

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

2. 使用 stateCount() 搜索每个点以查找指定值

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

使用 stateCount() 的示例查询

以下查询在过去 5 分钟内搜索 doors bucket，并计算有多少点的 _value 为 closed。

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

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

查询结果

上述示例查询的结果可能如下所示（为简单起见，我们省略了 measurement、tag 和 field 列）

_time                   _value        door_closed
2019-10-26T17:39:16Z    closed        1
2019-10-26T17:40:16Z    closed        2
2019-10-26T17:41:16Z    closed        3
2019-10-26T17:42:16Z    open          -1
2019-10-26T17:43:16Z    closed        1
2019-10-26T17:44:27Z    closed        2

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

以下查询每分钟检查机器状态（空闲、已分配或忙碌）。InfluxDB 在过去一小时内搜索 servers bucket，并计算机器状态为 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")