From 4f26ff32deaa0044cf878190a7aab131e48c2b05 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 4 Apr 2025 14:20:34 +0800 Subject: [PATCH] Refine --- influxdb_api.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/influxdb_api.py b/influxdb_api.py index 6e2f1c1..f5db75a 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1494,10 +1494,10 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start for device_id in query_ids_list: flux_query = f''' from(bucket: "{bucket}") - |> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()}) |> filter(fn: (r) => r["device_ID"] = {device_id} and r["_field"] == "monitored_value") |> sort(columns: ["_time"]) ''' + #|> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()}) # 执行查询，返回一个 FluxTable 列表 tables = query_api.query(flux_query)