InfluxQLQuery
Query InfluxDB using InfluxQL.
Execute an InfluxQL query against InfluxDB.
type: "io.kestra.plugin.influxdb.InfluxQLQuery"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
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.
NONESTOREFETCHFETCH_ONENONEThe 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.
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.
uriThe 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