Sink plugin: InfluxDB [Flink]
Write data to InfluxDB.
name | type | required | default value |
---|---|---|---|
server_url | String |
yes | - |
username | String |
no | - |
password | String |
no | - |
database | String |
yes | - |
measurement | String |
yes | - |
tags | List<String> |
yes | - |
fields | 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 Tag in InfluxDB.
The list of Field in InfluxDB.
The parallelism of an individual operator, for InfluxDbSink
InfluxDbSink {
server_url = "http://127.0.0.1:8086/"
database = "influxdb"
measurement = "m"
tags = ["country", "city"]
fields = ["count"]
}
InfluxDbSink {
server_url = "http://127.0.0.1:8086/"
username = "admin"
password = "password"
database = "influxdb"
measurement = "m"
tags = ["country", "city"]
fields = ["count"]
}