2.7 KiB
2.7 KiB
title | description | aliases | menu | weight | flux/v0.x/tags | introduced | ||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
monitor.deadman() function | The `monitor.deadman()` function detects when a group stops reporting data. |
|
|
202 |
|
0.39.0 |
The monitor.deadman()
function detects when a group stops reporting data.
It takes a stream of tables and reports if groups have been observed since time t
.
import "influxdata/influxdb/monitor"
monitor.deadman(t: 2019-08-30T12:30:00Z)
monitor.deadman()
retains the most recent row from each input table and adds a dead
column.
If a record appears after time t
, monitor.deadman()
sets dead
to false
.
Otherwise, dead
is set to true
.
Parameters
t
The time threshold for the deadman check.
tables
Input data.
Default is piped-forward data (<-
).
Examples
Detect if a host hasn't reported in the last five minutes
import "influxdata/influxdb/monitor"
import "experimental"
from(bucket: "example-bucket")
|> range(start: -10m)
|> group(columns: ["host"])
|> monitor.deadman(t: experimental.subDuration(d: 5m, from: now()))
{{< expand-wrapper >}} {{% expand "View example input and output" %}}
Example input data
_start | _stop | _time | _measurement | _host | _field | _value |
---|---|---|---|---|---|---|
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:00:00Z | example | h1 | resp | 200 |
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:00:30Z | example | h1 | resp | 200 |
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:01:00Z | example | h1 | resp | 500 |
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:01:30Z | example | h1 | resp | 500 |
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:02:00Z | example | h1 | resp | 200 |
Example output data
_start | _stop | _time | _measurement | _host | _field | _value | dead |
---|---|---|---|---|---|---|---|
2021-01-01T00:00:00Z | 2021-01-01T00:03:00Z | 2021-01-01T00:02:00Z | example | h1 | resp | 200 | true |
{{% /expand %}} | |||||||
{{< /expand-wrapper >}} |