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-02-24 20:57:18 +08:00
parent 7737b4a190
commit 64389c8a81
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
influxdb_api.py
View File

@@ -1355,12 +1355,10 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r
utc_time = time_api.to_utc_time(query_date + "T00:00:00+08:00")
start_time = time_api.get_utc_beginning(utc_time)
print(start_time)
stop_time = time_api.get_utc_after(start_time, hours=1)
print(stop_time)
# 构建 Flux 查询语句
flux_query = f'''
from(bucket: "{bucket}")
|> range(start: {str(start_time)}, stop: {str(stop_time)})
|> range(start: {str(start_time)})
|> filter(fn: (r) => r["_measurement"] == "node" or r["_measurement"] == "link")
|> filter(fn: (r) => r["date"] == "{query_date}")
|> pivot(