From 460aa7922459464f068855f956768ea5a01c4e37 Mon Sep 17 00:00:00 2001
From: DingZQ <zqding@hotmail.com>
Date: Sat, 15 Feb 2025 14:59:40 +0800
Subject: [PATCH] Update the query for scada

---
 influxdb_api.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/influxdb_api.py b/influxdb_api.py
index fc64c61..7f15d4a 100644
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -13,6 +13,7 @@ import schedule
 import threading
 import globals
 import influxdb_info
+import time_api
 
 # influxdb数据库连接信息
 url = influxdb_info.url
@@ -1170,7 +1171,7 @@ def query_latest_record_by_ID(ID: str, type: str, bucket: str="realtime_simulati
         flux_query = f'''
         from(bucket: "SCADA_data")
           |> range(start: -30d)  // 查找最近一月的记录
-          |> filter(fn: (r) => r["_measurement"] == "reservoir_liquid_level_realtime")
+          |> filter(fn: (r) => r["_measurement"] == "pressure_realtime")
           |> filter(fn: (r) => r["device_ID"] == "{ID}")
           |> pivot(
               rowKey:["_time"],