monitor.deadman() 函数
monitor.deadman() 检测组何时停止报告数据。它接受表流，并报告自时间 t 以来是否已观察到组。
monitor.deadman() 保留来自每个输入表的最新行，并添加一个 dead 列。如果记录在时间 t 之后出现，则 monitor.deadman() 将 dead 设置为 false。否则，dead 设置为 true。
函数类型签名
(<-tables: stream[{B with _time: C}], t: A) => stream[{B with dead: bool, _time: C}] where A: Comparable, C: Comparable
有关更多信息，请参阅 函数类型签名。
参数
t
（必需）deadman 检查的时间阈值。
tables
输入数据。默认为管道转发数据 (<-)。
示例
检测主机是否自特定时间以来未报告
import "array"
import "influxdata/influxdb/monitor"
data =
array.from(
rows: [
{_time: 2021-01-01T00:00:00Z, host: "a", _value: 1.2},
{_time: 2021-01-01T00:01:00Z, host: "a", _value: 1.3},
{_time: 2021-01-01T00:02:00Z, host: "a", _value: 1.4},
{_time: 2021-01-01T00:03:00Z, host: "a", _value: 1.3},
],
)
|> group(columns: ["host"])
data
|> monitor.deadman(t: 2021-01-01T00:05:00Z)
检测主机是否自相对时间以来未报告
使用 date.add() 返回相对于指定时间的时间值。
import "influxdata/influxdb/monitor"
import "date"
from(bucket: "example-bucket")
|> range(start: -10m)
|> filter(fn: (r) => r._measurement == "example-measurement")
|> monitor.deadman(t: date.add(d: -5m, to: now()))
此页面是否对您有帮助？
感谢您的反馈！