InfluxQLQuery

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

Examples

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

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

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

InfluxQLQuery

More Plugins in this Category

Core Plugins and tasks

PostgreSQL

SurrealDB

1.1.2