InfluxDB FluxQuery

InfluxDB FluxQuery

Certified

Run Flux query against InfluxDB

Executes a Flux query for a given organization. The bucket parameter is ignored because the query embeds it; fetchType controls whether rows are returned, stored as ION, or only counted.

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
Properties

InfluxDB connection

Connection settings (URL, token, optional options) reused across tasks

Definitions
token*Requiredstring

InfluxDB token

The authentication token for InfluxDB

url*Requiredstring

InfluxDB server URL

The URL of the InfluxDB server

connectTimeoutstring
DefaultPT10S

Connection timeout.

Connection establishment timeout (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.

readTimeoutstring
DefaultPT10S

Read timeout.

Maximum time to wait for response bytes (including initial response) (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.

Organization name

Organization scope for queries and writes

Query string

Flux or InfluxQL statement to run against InfluxDB

Bucket name

Target bucket for write/query operations when required; ignored by Flux queries

DefaultNONE
Possible Values
STOREFETCHFETCH_ONENONE

Fetch behavior

FETCH_ONE returns the first row, FETCH returns all rows, STORE writes rows to an ION file, NONE only records metrics; default is NONE

Reference (ref) of the pluginDefaults to apply to this task.

First fetched row

Only populated when fetchType=FETCH_ONE

SubTypeobject

Fetched rows

Only populated when fetchType=FETCH

Number of rows returned

Total rows without pagination

Formaturi

URI of stored data

Only populated when fetchType=STORE

Unitcount

The number of records returned by the query

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints