FluxQuery

Query InfluxDB using Flux language.

Execute a Flux query against InfluxDB.

yaml
type: "io.kestra.plugin.influxdb.FluxQuery"

Query data from InfluxDB and store as ION file

yaml
id: influxdb_flux_query
namespace: company.team

tasks:
  - id: query_influxdb
    type: io.kestra.plugin.influxdb.FluxQuery
    connection:
      url: "{{ secret('INFLUXDB_URL') }}"
      token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "my-org"
    query: |
      from(bucket: "my-bucket")
        |> range(start: -1h)
        |> filter(fn: (r) => r._measurement == "cpu")
        |> yield()
    fetchType: STORE

Query data from InfluxDB and return all rows in execution output.

yaml
id: influxdb_flux_query_inline
namespace: company.team

tasks:
  - id: query_influxdb
    type: io.kestra.plugin.influxdb.FluxQuery
    connection:
      url: "{{ secret('INFLUXDB_URL') }}"
      token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "my-org"
    query: |
      from(bucket: "my-bucket")
        |> range(start: -1h)
        |> filter(fn: (r) => r._measurement == "cpu")
        |> limit(n: 10)
        |> yield()
    fetchType: FETCH

Query data from InfluxDB and return only the first row.

yaml
id: influxdb_flux_query_one
namespace: company.team

tasks:
  - id: query_influxdb
    type: io.kestra.plugin.influxdb.FluxQuery
    connection:
      url: "{{ secret('INFLUXDB_URL') }}"
      token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "my-org"
    query: |
      from(bucket: "my-bucket")
        |> range(start: -1h)
        |> filter(fn: (r) => r._measurement == "cpu")
        |> limit(n: 1)
        |> yield()
    fetchType: FETCH_ONE

InfluxDB connection properties.

InfluxDB organization.

The organization to use for operations.

Query to execute

Query to run against InfluxDB

InfluxDB bucket.

The bucket to use for operations.

Default NONE

Possible Values

STOREFETCHFETCH_ONENONE

The way you want to store the data.

FETCH_ONE output the first row, FETCH output all the rows, STORE store all rows in a file, NONE do nothing.

Map containing the first row of fetched data.

Only populated if using fetchType=FETCH_ONE.

SubType object

List containing the fetched data.

Only populated if using fetchType=FETCH.

The number of rows fetched.

The total number of the rows fetched without pagination.

Format uri

The URI of the stored data.

Only populated if using fetchType=STORE.

InfluxDB token

The authentication token for InfluxDB

InfluxDB server URL

The URL of the InfluxDB server

​Flux​Query

FluxQuery