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

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