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.

*Function type: Transformation*

import "influxdata/influxdb/monitor"
monitor.stateChanges(
  fromLevel: "any",
  toLevel: "any"
)

Parameters

fromLevel

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

*Data type: String*

toLevel

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

*Data type: String*

Examples

Detect when the state changes to critical

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

Given the following input:

The following function outputs:

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)
}