experimental.chain() function

The experimental.chain() function runs two queries in a single Flux script sequentially and outputs the results of the second query. Flux typically executes multiple queries in a single script in parallel. Running the queries sequentially ensures any dependencies the second query has on the results of the first query are met.

Applicable use cases
  • Writing to a bucket and querying the written data in a single Flux script or InfluxDB task.

The first query to execute.

The second query to execute.

Examples

  1. import "experimental"
  3. downsampled_max = from(bucket: "example-bucket-1")
  4.   |> range(start: -1d)
  6.   |> aggregateWindow(every: 1h, fn: max)
  7.   |> to(bucket: "downsample-1h-max", org: "example-org")
  8. average_max = from(bucket: "downsample-1h-max")
  9.   |> range(start: -1d)
  11.   |> mean()
  13. experimental.chain(
  14.   first: downsampled_max,