InfluxDB
Description
Write data to InfluxDB.
提示
Engine Supported and plugin name
- Spark
- Flink: InfluxDB
Options
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 | - |
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.
tags [List<String>
]
The list of Tag in InfluxDB.
fields [List<String>
]
The list of Field in InfluxDB.
parallelism [Int
]
The parallelism of an individual operator, for InfluxDbSink
Example
Simple
InfluxDbSink {
server_url = "http://127.0.0.1:8086/"
database = "influxdb"
measurement = "m"
tags = ["country", "city"]
fields = ["count"]
}
Auth
InfluxDbSink {
server_url = "http://127.0.0.1:8086/"
username = "admin"
password = "password"
database = "influxdb"
measurement = "m"
tags = ["country", "city"]
fields = ["count"]
}