InfluxDB Load

InfluxDB Load

Certified

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.

yaml
type: io.kestra.plugin.influxdb.Load

Load data points to InfluxDB from an ION file.

yaml
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

InfluxDB connection

Connection settings (URL, token, optional options) reused across tasks

Definitions
token*Requiredstring

InfluxDB token

The authentication token for InfluxDB

url*Requiredstring

InfluxDB server URL

The URL of the InfluxDB server

connectTimeoutstring
DefaultPT10S

Connection timeout.

Connection establishment timeout (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.

readTimeoutstring
DefaultPT10S

Read timeout.

Maximum time to wait for response bytes (including initial response) (ISO-8601 duration, e.g. PT10S). Default is 10 seconds.

Source file URI

URI in internal storage (e.g., kestra://...) containing the data to load

Measurement for all points

Measurement applied to every point from the ION file

Organization name

Organization scope for queries and writes

Bucket name

Target bucket for write/query operations when required; ignored by Flux queries

Default1000

Chunk size per write

Number of points per batch when writing to InfluxDB; defaults to 1000

Reference (ref) of the pluginDefaults to apply to this task.

SubTypestring

Fields treated as tags

Fields listed here are stored as tags; remaining keys become fields

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

Number of records written to InfluxDB

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints