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 *RequiredNon-dynamicInfluxDBConnection
org *Requiredstring
query *Requiredstring
bucket string
fetchType string
Default
NONE
Possible Values
STORE
FETCH
FETCH_ONE
NONE
Outputs
row object
rows array
SubType object
size integer
total integer
uri string
Format
uri