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:36:00 +08:00
parent d3e2961c60
commit 5cf7efc3a9
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb_api.py
View File

@@ -1378,6 +1378,8 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r
for record in table.records: for record in table.records:
# print(record.values) # 打印完整记录内容 # print(record.values) # 打印完整记录内容
measurement = record["_measurement"] measurement = record["_measurement"]
print(measurement)
# 处理 node 数据 # 处理 node 数据
if measurement == "node": if measurement == "node":
node_records.append({ node_records.append({