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

Refine

Browse Source
This commit is contained in:
DingZQ
2025-03-22 15:23:19 +08:00
parent 3f5b7e2319
commit 51d45ef192
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb_api.py
View File

@@ -1461,8 +1461,6 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start
from(bucket: "{bucket}") from(bucket: "{bucket}")
|> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()}) |> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()})
|> filter(fn: (r) => r["device_ID"] == "{device_id}" and r["_field"] == "monitored_value") |> filter(fn: (r) => r["device_ID"] == "{device_id}" and r["_field"] == "monitored_value")
|> pivot(rowKey: ["_time"], columnKey: ["device_ID"], valueColumn: "_value")
|> sort(columns: ["_time"])
''' '''
# 执行查询，返回一个 FluxTable 列表 # 执行查询，返回一个 FluxTable 列表
tables = query_api.query(flux_query) tables = query_api.query(flux_query)