OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

'We

Browse Source
This commit is contained in:
DingZQ
2025-03-21 21:53:42 +08:00
parent 442dab54da
commit 7108e8f70d
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
influxdb_api.py
View File

@@ -102,7 +102,8 @@ def query_pg_scada_info_non_realtime(name: str) -> None:
open_project(name) open_project(name)
dic_time = get_time(name) dic_time = get_time(name)
globals.hydraulic_timestep = dic_time['HYDRAULIC TIMESTEP'] globals.hydraulic_timestep = dic_time['HYDRAULIC TIMESTEP']
close_project(name) # DingZQ, 2025-03-21
#close_project(name)
# 连接数据库 # 连接数据库
conn_string = f"dbname={name} host=127.0.0.1" conn_string = f"dbname={name} host=127.0.0.1"
try: try:

4
online_Analysis.py
View File

@@ -49,6 +49,10 @@ def burst_analysis(name: str, modify_pattern_start_time: str, burst_ID: list | s
print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Start Copying Database.") print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Start Copying Database.")
CopyProjectEx()(name, new_name, CopyProjectEx()(name, new_name,
['operation', 'current_operation', 'restore_operation', 'batch_operation', 'operation_table']) ['operation', 'current_operation', 'restore_operation', 'batch_operation', 'operation_table'])
# DingZQ, 2025-03-21
open_project(name)
print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Start Opening Database.") print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Start Opening Database.")
open_project(new_name) open_project(new_name)
print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Database Loading OK.") print(datetime.now(pytz.timezone('Asia/Shanghai')).strftime("%Y-%m-%d %H:%M:%S") + " -- Database Loading OK.")