monitor.stateChanges() function

The monitor.stateChanges() function detects state changes in a stream of data with a _level column and outputs records that change from fromLevel to toLevel.

import "influxdata/influxdb/monitor"

monitor.stateChanges(
  fromLevel: "any",
  toLevel: "any"
)

Parameters

fromLevel

The level to detect a change from. Defaults to "any".

toLevel

The level to detect a change to. The function output records that change to this level. Defaults to "any".

tables

Input data. Default is piped-forward data (<-).

Examples

Detect when the state changes to critical

import "influxdata/influxdb/monitor"

monitor.from(start: -1h)
  |> monitor.stateChanges(toLevel: "crit")

Function definition

stateChanges = (fromLevel="any", toLevel="any", tables=<-) => {
  return
    if fromLevel == "any" and toLevel == "any" then tables |> stateChangesOnly()
    else tables |> _stateChanges(fromLevel: fromLevel, toLevel: toLevel)
}