Query InfluxDB using Flux language.
Execute a Flux query against InfluxDB.
type: "io.kestra.plugin.influxdb.fluxquery"Query data from InfluxDB and store as ION file
id: influxdb_flux_query
namespace: company.team
tasks:
- id: query_influxdb
type: io.kestra.plugin.influxdb.FluxQuery
connection:
url: "{{ secret('INFLUXDB_URL') }}"
token: "{{ secret('INFLUXDB_TOKEN') }}"
org: "my-org"
query: |
from(bucket: "my-bucket")
|> range(start: -1h)
|> filter(fn: (r) => r._measurement == "cpu")
|> yield()
fetchType: STORE
Query data from InfluxDB and return all rows in execution output.
id: influxdb_flux_query_inline
namespace: company.team
tasks:
- id: query_influxdb
type: io.kestra.plugin.influxdb.FluxQuery
connection:
url: "{{ secret('INFLUXDB_URL') }}"
token: "{{ secret('INFLUXDB_TOKEN') }}"
org: "my-org"
query: |
from(bucket: "my-bucket")
|> range(start: -1h)
|> filter(fn: (r) => r._measurement == "cpu")
|> limit(n: 10)
|> yield()
fetchType: FETCH
Query data from InfluxDB and return only the first row.
id: influxdb_flux_query_one
namespace: company.team
tasks:
- id: query_influxdb
type: io.kestra.plugin.influxdb.FluxQuery
connection:
url: "{{ secret('INFLUXDB_URL') }}"
token: "{{ secret('INFLUXDB_TOKEN') }}"
org: "my-org"
query: |
from(bucket: "my-bucket")
|> range(start: -1h)
|> filter(fn: (r) => r._measurement == "cpu")
|> limit(n: 1)
|> yield()
fetchType: FETCH_ONE
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