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-04 21:43:36 +08:00
parent e818522de8
commit 47b3b8644d
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
influxdb_api.py
View File

@@ -1814,11 +1814,15 @@ def query_all_record_by_date_property(query_date: str, type: str, property: str,
# 构建 Flux 查询语句 # 构建 Flux 查询语句
flux_query = f''' flux_query = f'''
from(bucket: "{bucket}") from(bucket: "{bucket}")
|> range(start: {start_time}, stop: {stop_time}) |> range(start: {start_time.isoformat()}, stop: {stop_time.isoformat()})
|> filter(fn: (r) => r["_measurement"] == "{measurement}") |> filter(fn: (r) =>
|> filter(fn: (r) => r["date"] == "{query_date}") r._measurement == "{measurement}" and
|> filter(fn: (r) => r["_field"] == "{property}") r._field == "{property}"
)
|> group(columns: ["date"])
|> filter(fn: (r) => r.date == "{query_date}")
|> keep(columns: ["_time", "_value", "date"])
''' '''
# 执行查询 # 执行查询
tables = query_api.query(flux_query) tables = query_api.query(flux_query)