InfluxQLQuery
Query InfluxDB using InfluxQL.
Query InfluxDB using InfluxQL.
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-dynamic
InfluxDB connection properties.
io.kestra.plugin.influxdb.InfluxDBConnection
InfluxDB token
The authentication token for InfluxDB
InfluxDB server URL
The URL of the InfluxDB server
PT10SdurationConnection timeout.
Connection establishment timeout (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.
PT10SdurationRead timeout.
Maximum time to wait for response bytes (including initial response) (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.
org*Requiredstring
InfluxDB organization.
The organization to use for operations.
query*Requiredstring
Query to execute
Query to run against InfluxDB
bucketstring
InfluxDB bucket.
The bucket to use for operations.
fetchTypestring
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.
Outputs
rowobject
Map containing the first row of fetched data.
Only populated if using fetchType=FETCH_ONE.
rowsarray
List containing the fetched data.
Only populated if using fetchType=FETCH.
sizeinteger
The number of rows fetched.
totalinteger
The total number of the rows fetched without pagination.
uristring
uriThe URI of the stored data.
Only populated if using fetchType=STORE.
Metrics
recordscounter
countThe number of records returned by the query
