Source plugin: InfluxDb [Flink]
Read data from InfluxDB.
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 | - |
The URL of InfluxDB Server.
The username of InfluxDB Server.
The password of InfluxDB Server.
The database name in InfluxDB.
The Measurement name in InfluxDB.
The list of Field in InfluxDB.
The list of Field Types in InfluxDB.
The parallelism of an individual operator, for InfluxDbSource.
InfluxDbSource {
server_url = "http://127.0.0.1:8086/"
database = "influxdb"
measurement = "m"
fields = ["time", "temperature"]
field_types = ["STRING", "DOUBLE"]
}
InfluxDbSource {
server_url = "http://127.0.0.1:8086/"
username = "admin"
password = "password"
database = "influxdb"
measurement = "m"
fields = ["time", "temperature"]
field_types = ["STRING", "DOUBLE"]
}