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を操作する基本的な手順です。詳細な情報や他の操作については、公式ドキュメンテーションを参照してください。.