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"],