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 21:01:59 +08:00
parent 7151476709
commit 7e075cb02d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb_api.py
View File

@@ -1359,7 +1359,7 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r
# 构建 Flux 查询语句 # 构建 Flux 查询语句
flux_query = f''' flux_query = f'''
from(bucket: "{bucket}") from(bucket: "{bucket}")
|> range(start: {str(start_time)}) |> range(start: {start_time})
|> filter(fn: (r) => r["_measurement"] == "node" or r["_measurement"] == "link") |> filter(fn: (r) => r["_measurement"] == "node" or r["_measurement"] == "link")
|> filter(fn: (r) => r["date"] == "{query_date}") |> filter(fn: (r) => r["date"] == "{query_date}")
|> pivot( |> pivot(