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-15 14:05:59 +08:00
parent 9a541b0d73
commit c146f68fc7
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
influxdb_api.py
View File

@@ -2136,6 +2136,9 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
jitter_interval=200, # 添加抖动以避免同时写入 jitter_interval=200, # 添加抖动以避免同时写入
max_retry_delay=30000 # 最大重试延迟（毫秒） max_retry_delay=30000 # 最大重试延迟（毫秒）
) )
print("fill_scheme_simulation_result_to_SCADA")
write_api = client.write_api(write_options=write_options) write_api = client.write_api(write_options=write_options)
# 创建一个临时存储点数据的列表 # 创建一个临时存储点数据的列表
points_to_write = [] points_to_write = []
@@ -2157,6 +2160,8 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
points_to_write.append(point) points_to_write.append(point)
# write_api.write(bucket=bucket, org=org_name, record=point) # write_api.write(bucket=bucket, org=org_name, record=point)
print("fill_scheme_simulation_result_to_SCADA 2163")
for key, value in globals.scheme_pipe_flow_ids.items(): for key, value in globals.scheme_pipe_flow_ids.items():
scheme_pipe_flow_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name, scheme_pipe_flow_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name,
query_date=query_date, ID=value, type='link', property='flow')) query_date=query_date, ID=value, type='link', property='flow'))
@@ -2173,6 +2178,8 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
points_to_write.append(point) points_to_write.append(point)
# write_api.write(bucket=bucket, org=org_name, record=point) # write_api.write(bucket=bucket, org=org_name, record=point)
print("fill_scheme_simulation_result_to_SCADA - 2181")
for key, value in globals.scheme_pressure_ids.items(): for key, value in globals.scheme_pressure_ids.items():
scheme_pressure_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name, scheme_pressure_result = (query_scheme_curve_by_ID_property(scheme_Type=scheme_Type, scheme_Name=scheme_Name,
query_date=query_date, ID=value, type='node', property='pressure')) query_date=query_date, ID=value, type='node', property='pressure'))
@@ -2220,6 +2227,9 @@ def fill_scheme_simulation_result_to_SCADA(scheme_Type: str = None, scheme_Name:
) )
points_to_write.append(point) points_to_write.append(point)
# write_api.write(bucket=bucket, org=org_name, record=point) # write_api.write(bucket=bucket, org=org_name, record=point)
print('fill_scheme_simulation_result_to_SCADA - 2231')
# 批量写入数据 # 批量写入数据
if points_to_write: if points_to_write:
write_api.write(bucket=bucket, org=org_name, record=points_to_write) write_api.write(bucket=bucket, org=org_name, record=points_to_write)