Load

Load data points to InfluxDB from a file.

Load data points to InfluxDB from an ION file where each record becomes a data point.

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

Examples

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

connection *InfluxDBConnection

InfluxDB connection properties.

from *string

The source file URI

URI of the file containing data to be loaded into InfluxDB

Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.

measurement *string

Measurement name

The measurement name to be used for all points from the ION file

org *string

InfluxDB organization.

The organization to use for operations.

bucket string

InfluxDB bucket.

The bucket to use for operations.

chunk integerstring

Default 1000

Chunk size for each bulk write request

Number of points to include in each write batch

tags array

SubType string

List of field names to use as tags

Fields listed here will be added as tags; all others will be added as fields

timeField string

Field name to use as timestamp

The field containing timestamp values. If null, InfluxDB will use the current time.

Outputs

recordCount integer

Number of records written to InfluxDB

Definitions

io.kestra.plugin.influxdb.InfluxDBConnection

token *string

InfluxDB token

The authentication token for InfluxDB

url *string

InfluxDB server URL

The URL of the InfluxDB server

​Load

Load