Python で InfluxDB へ書き込みを行う方法です。
環境
- Windows 10
- Python 3.8.1
ライブラリのインストール
pip でライブラリをインストールします。
> pip install influxdb
サンプルコード
まずは InfluxDBClient をインポートして、クライアントを作成します。
from influxdb import InfluxDBClient
# クライアントの作成
client = InfluxDBClient(host="127.0.0.1",
port=8086,
username="username",
password="password",
database="dbname")
DB の作成
client.create_database("dbname")
リテンションポリシーの作成
client.create_retention_policy("rpname", "30d", 1)
データの書き込み
client.write_points([
{
'fields': {
'hoge': 'hoge',
},
'measurement': 'piyo',
'time': time.time(),
'tags': {
'fuga': 'fuga',
}
},
],
retention_policy="リテンションポリシー名")
