InfluxQLQuery
Query InfluxDB using InfluxQL.
Execute an InfluxQL query against InfluxDB.
type: "io.kestra.plugin.influxdb.InfluxQLQuery"
Examples
Execute an InfluxQL query.
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
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 *RequiredNon-dynamicInfluxDBConnection
InfluxDB connection properties.
org *Requiredstring
InfluxDB organization.
The organization to use for operations.
query *Requiredstring
Query to execute
Query to run against InfluxDB
bucket string
InfluxDB bucket.
The bucket to use for operations.
fetchType string
NONE
STORE
FETCH
FETCH_ONE
NONE
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.
Outputs
row object
Map containing the first row of fetched data.
Only populated if using fetchType=FETCH_ONE
.
rows array
List containing the fetched data.
Only populated if using fetchType=FETCH
.
size integer
The number of rows fetched.
total integer
The total number of the rows fetched without pagination.
uri string
uri
The URI of the stored data.
Only populated if using fetchType=STORE
.
Definitions
io.kestra.plugin.influxdb.InfluxDBConnection
token *Requiredstring
InfluxDB token
The authentication token for InfluxDB
url *Requiredstring
InfluxDB server URL
The URL of the InfluxDB server