InfluxDB InfluxQLQuery
CertifiedRun InfluxQL query against InfluxDB
InfluxDB InfluxQLQuery
Run InfluxQL query against InfluxDB
Executes an InfluxQL query for the specified bucket and organization. fetchType controls whether rows are returned inline, stored, or just counted.
type: io.kestra.plugin.influxdb.InfluxQLQueryExamples
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 *
InfluxDB connection
Connection settings (URL, token, optional options) reused across tasks
io.kestra.plugin.influxdb.InfluxDBConnection
InfluxDB token
The authentication token for InfluxDB
InfluxDB server URL
The URL of the InfluxDB server
PT10SConnection timeout.
Connection establishment timeout (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.
PT10SRead timeout.
Maximum time to wait for response bytes (including initial response) (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.
org *string
Organization name
Organization scope for queries and writes
query *string
Query string
Flux or InfluxQL statement to run against InfluxDB
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150bucket string
Bucket name
Target bucket for write/query operations when required; ignored by Flux queries
fetchType string
NONESTOREFETCHFETCH_ONENONEFetch behavior
FETCH_ONE returns the first row, FETCH returns all rows, STORE writes rows to an ION file, NONE only records metrics; default is NONE
Outputs
row object
First fetched row
Only populated when fetchType=FETCH_ONE
rows array
Fetched rows
Only populated when fetchType=FETCH
size integer
Number of rows returned
total integer
Total rows without pagination
uri string
uriURI of stored data
Only populated when fetchType=STORE
Metrics
records counter
countThe number of records returned by the query
