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-04-19 11:28:57 +08:00
parent edc6d6d9c2
commit 4a8130a748
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

@@ -1814,8 +1814,8 @@ def store_realtime_simulation_result_to_influxdb(node_result_list: List[Dict[str
write_api.write(bucket=bucket, org=org_name, record=points_to_write) write_api.write(bucket=bucket, org=org_name, record=points_to_write)
write_api.flush() # 刷新缓存一次 write_api.flush() # 刷新缓存一次
except Exception as e: except Exception as e:
client.close()
raise RuntimeError(f"数据写入 InfluxDB 时发生错误: {e}") raise RuntimeError(f"数据写入 InfluxDB 时发生错误: {e}")
client.close()
time.sleep(10) time.sleep(10)
print("Total points written:", points_written) print("Total points written:", points_written)