PythonでInfluxDBを操作する方法

InfluxDBは時系列データの扱いに特化したデータベースであり、PythonのAPIを使って操作することができます。ここでは、PythonでInfluxDBにデータを書き込み、クエリを実行する基本的な手順を説明します。

データの書き込み

まず、InfluxDB Pythonクライアントライブラリをインストールします。

pip install influxdb-client

次に、以下のPythonコードを使用してInfluxDBにデータを書き込みます。

import influxdb_client
from influxdb_client.client.write_api import SYNCHRONOUS

bucket = "<my-bucket>"
org = "<my-org>"
token = "<my-token>"
url = "http://localhost:8086"

client = influxdb_client.InfluxDBClient(url=url, token=token, org=org)
write_api = client.write_api(write_options=SYNCHRONOUS)

p = influxdb_client.Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)
write_api.write(bucket=bucket, org=org, record=p)

データのクエリ

次に、以下のPythonコードを使用してInfluxDBからデータをクエリします。

query_api = client.query_api()

query = 'from (bucket:"my-bucket")\\ |> range (start: -10m)\\ |> filter (fn: (r) => r._measurement == "my_measurement")\\ |> filter (fn: (r) => r.location == "Prague")\\ |> filter (fn: (r) => r._field == "temperature")'

result = query_api.query(org=org, query=query)

以上がPythonでInfluxDBを操作する基本的な手順です。詳細な情報や他の操作については、公式ドキュメンテーションを参照してください。.