OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update the query for scada

Browse Source
This commit is contained in:
DingZQ
2025-02-15 14:59:40 +08:00
parent 7db2b2c0ac
commit 460aa79224
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
influxdb_api.py
View File

@@ -13,6 +13,7 @@ import schedule
import threading import threading
import globals import globals
import influxdb_info import influxdb_info
import time_api
# influxdb数据库连接信息 # influxdb数据库连接信息
url = influxdb_info.url 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''' flux_query = f'''
from(bucket: "SCADA_data") from(bucket: "SCADA_data")
|> range(start: -30d) // 查找最近一月的记录 |> 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}") |> filter(fn: (r) => r["device_ID"] == "{ID}")
|> pivot( |> pivot(
rowKey:["_time"], rowKey:["_time"],