From 5867451b638803d0781f675ca415911a24625458 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 4 Apr 2025 14:34:06 +0800 Subject: [PATCH] Refine --- influxdb_api.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/influxdb_api.py b/influxdb_api.py index b3e0468..849f630 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1505,17 +1505,16 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start # 从查询结果中提取 monitored_value if result: # 假设返回的结果为一行数据 - records_list = [] + records_list = [] - for table in result: - for record in table.records: - # 获取记录的时间和监测值 + for table in result: + for record in table.records: + # 获取记录的时间和监测值 records_list.append({ "time": record["_time"], "value": record["_value"] }) - - SCADA_dict[device_id] = records_list + SCADA_dict[device_id] = records_list except Exception as e: print(f"Error querying InfluxDB for device ID {device_id}: {e}")