InfluxQLQuery

Query InfluxDB using InfluxQL.

Execute an InfluxQL query against InfluxDB.

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

Execute an InfluxQL query.

yaml
id: influxdb_query
namespace: company.team

tasks:
  - id: query_influxdb
    type: io.kestra.plugin.influxdb.InfluxQLQuery
    connection:
      url: "{{ secret('INFLUXDB_URL') }}"
      token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "my-org"
    query: "SELECT * FROM measurement WHERE time > now() - 1h"
    fetchType: FETCH

Execute an InfluxQL query and store results as ION file

yaml
id: influxdb_query_to_file
namespace: company.team

tasks:
  - id: query_to_file
    type: io.kestra.plugin.influxdb.InfluxQLQuery
    connection:
      url: "{{ secret('INFLUXDB_URL') }}"
      token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "my-org"
    query: "SELECT * FROM measurement WHERE time > now() - 1h"
    fetchType: ION

Dynamic NO

InfluxDB connection properties.

Dynamic YES

InfluxDB organization.

The organization to use for operations.

Dynamic YES

Query to execute

Query to run against InfluxDB

Dynamic YES

InfluxDB bucket.

The bucket to use for operations.

Dynamic YES

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.

Dynamic YES

InfluxDB token

The authentication token for InfluxDB

Dynamic YES

InfluxDB server URL

The URL of the InfluxDB server

​Influx​Q​L​Query

InfluxQLQuery