Python API を使用して Flux クエリ言語を介して、InfluxDB 2.0 の特定の Measurement の最高の (最新の) タイムスタンプを取得する必要があります。
以下のクエリを使用してタイムスタンプを取得しましたが、この方法で抽出したタイムスタンプが実際に最新のものであることを確認する方法がわかりません。
特に、私が使用するインデックス は、 のようなオブジェクトのリストと同様にlast_data[0]任意であり、解釈方法がわかりません。タイムスタンプはソートされていないようです。last_data<influxdb_client.client.flux_table.FluxTable object at 0x00000193FA906AC8>
from influxdb_client import InfluxDBClient, WriteOptions
client = InfluxDBClient(url=self.influx_url, token=self.token, org=self.org_id, debug=False)
last_data = client.query_api().query(
f'from(bucket:"{self.influx_bucket}") |> range(start: -100d) |> filter(fn: (r) => r["_measurement"] == "{devices[0]}") |> last()'
)
timestamp = last_data[0].records[0]["_stop"]
print(timestamp)