FluxQuery

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

Examples

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

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

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

connection*

Definitions

io.kestra.plugin.influxdb.InfluxDBConnection

token*string

url*string

connectTimeoutstring

DefaultPT10S

Formatduration

readTimeoutstring

DefaultPT10S

Formatduration

org*string

query*string

bucketstring

fetchTypestring

DefaultNONE

Possible Values

STOREFETCHFETCH_ONENONE

Outputs

rowobject

rowsarray

SubTypeobject

sizeinteger

totalinteger

uristring

Formaturi

Metrics

recordscounter

Unitcount

Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

PostgreSQL

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

Database

SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

FluxQuery

More Plugins in this Category

Core Plugins and tasks

PostgreSQL

SurrealDB