InfluxDB Load
CertifiedLoad ION records into InfluxDB
InfluxDB Load
Load ION records into InfluxDB
Reads an ION file from internal storage and writes each object as a point to InfluxDB with nanosecond precision. Uses the provided measurement, batches writes in chunks of 1000 by default, and skips a time field unless timeField is set so InfluxDB assigns the server timestamp.
type: io.kestra.plugin.influxdb.LoadExamples
Load data points to InfluxDB from an ION file.
id: influxdb_load
namespace: company.team
inputs:
- id: file
type: FILE
tasks:
- id: load
type: io.kestra.plugin.influxdb.Load
connection:
url: "{{ secret('INFLUXDB_URL') }}"
token: "{{ secret('INFLUXDB_TOKEN') }}"
org: "{{ secret('INFLUXDB_ORG') }}"
bucket: "{{ secret('INFLUXDB_BUCKET') }}"
from: "{{ inputs.file }}"
measurement: "sensor_data"
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.
from *string
Source file URI
URI in internal storage (e.g., kestra://...) containing the data to load
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
measurement *string
Measurement for all points
Measurement applied to every point from the ION file
org *string
Organization name
Organization scope for queries and writes
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
chunk integerstring
1000Chunk size per write
Number of points per batch when writing to InfluxDB; defaults to 1000
timeField string
Timestamp field name
Field whose value becomes the point timestamp with nanosecond precision; when unset a time key is skipped and InfluxDB assigns the server time
Outputs
recordCount integer
Number of records written to InfluxDB
