Skip to content

Latest commit

 

History

History
80 lines (54 loc) · 1.63 KB

InfluxDb.md

File metadata and controls

80 lines (54 loc) · 1.63 KB
Raw

InfluxDb

Source plugin: InfluxDb [Flink]

Description

Read data from InfluxDB.

Options

name type required default value
server_url String yes -
username String no -
password String no -
database String yes -
measurement String yes -
fields List<String> yes -
field_types List<String> yes -
parallelism Int no -

server_url [String]

The URL of InfluxDB Server.

username [String]

The username of InfluxDB Server.

password [String]

The password of InfluxDB Server.

database [String]

The database name in InfluxDB.

measurement [String]

The Measurement name in InfluxDB.

fields [List<String>]

The list of Field in InfluxDB.

field_types [List<String>]

The list of Field Types in InfluxDB.

parallelism [Int]

The parallelism of an individual operator, for InfluxDbSource.

Example

Simple

InfluxDbSource {
  server_url = "http://127.0.0.1:8086/"
  database = "influxdb"
  measurement = "m"
  fields = ["time", "temperature"]
  field_types = ["STRING", "DOUBLE"]
}

Auth

InfluxDbSource {
  server_url = "http://127.0.0.1:8086/"
  username = "admin"
  password = "password"
  database = "influxdb"
  measurement = "m"
  fields = ["time", "temperature"]
  field_types = ["STRING", "DOUBLE"]
}