Skip to main content
Version: 2.1.1

InfluxDb

Description​

Read data from InfluxDB.

tip

Engine Supported and plugin name

  • Spark
  • Flink: InfluxDb

Options​

nametyperequireddefault value
server_urlStringyes-
usernameStringno-
passwordStringno-
databaseStringyes-
measurementStringyes-
fieldsList<String>yes-
field_typesList<String>yes-
parallelismIntno-

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"]
}