InfluxDB InfluxQLQuery

InfluxDB InfluxQLQuery

Certified

Run InfluxQL query against InfluxDB

Executes an InfluxQL query for the specified bucket and organization. fetchType controls whether rows are returned inline, stored, or just counted.

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
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