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

Change bb to project_info.name

Browse Source
This commit is contained in:
DingZQ
2025-08-13 18:12:05 +08:00
parent d745e6f011
commit e4b1648041
9 changed files with 34 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
auto_realtime.py
View File

@@ -10,6 +10,7 @@ import shutil
from influxdb_client import InfluxDBClient, BucketsApi, WriteApi, OrganizationsApi, Point, QueryApi
import simulation
import influxdb_info
import project_info
def setup_logger():
# 创建日志目录
@@ -103,19 +104,19 @@ def run_simulation_job() -> None:
if current_time.minute % 15 == 0:
print(f"{current_time.strftime('%Y-%m-%d %H:%M:%S')} -- Start simulation task.")
# 计算前，获取scada_info中的信息，按照设定的方法修改pg数据库
simulation.query_corresponding_element_id_and_query_id("bb")
simulation.query_corresponding_pattern_id_and_query_id('bb')
region_result = simulation.query_non_realtime_region('bb')
globals.source_outflow_region_id = simulation.get_source_outflow_region_id('bb', region_result)
globals.realtime_region_pipe_flow_and_demand_id = simulation.query_realtime_region_pipe_flow_and_demand_id('bb', region_result)
globals.pipe_flow_region_patterns = simulation.query_pipe_flow_region_patterns('bb')
globals.non_realtime_region_patterns = simulation.query_non_realtime_region_patterns('bb', region_result)
globals.source_outflow_region_patterns, realtime_region_pipe_flow_and_demand_patterns = simulation.get_realtime_region_patterns('bb',
simulation.query_corresponding_element_id_and_query_id(project_info.name)
simulation.query_corresponding_pattern_id_and_query_id(project_info.name)
region_result = simulation.query_non_realtime_region(project_info.name)
globals.source_outflow_region_id = simulation.get_source_outflow_region_id(project_info.name, region_result)
globals.realtime_region_pipe_flow_and_demand_id = simulation.query_realtime_region_pipe_flow_and_demand_id(project_info.name, region_result)
globals.pipe_flow_region_patterns = simulation.query_pipe_flow_region_patterns(project_info.name)
globals.non_realtime_region_patterns = simulation.query_non_realtime_region_patterns(project_info.name, region_result)
globals.source_outflow_region_patterns, realtime_region_pipe_flow_and_demand_patterns = simulation.get_realtime_region_patterns(project_info.name,
globals.source_outflow_region_id,
globals.realtime_region_pipe_flow_and_demand_id)
modify_pattern_start_time: str = get_next_15minute_time() # 获取下一个15分钟时间点
# print(modify_pattern_start_time)
simulation.run_simulation(name='bb', simulation_type="realtime", modify_pattern_start_time=modify_pattern_start_time)
simulation.run_simulation(name=project_info.name, simulation_type="realtime", modify_pattern_start_time=modify_pattern_start_time)
logger.info('{} -- Successfully run simulation and store realtime simulation result.'.format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
else:
@@ -150,6 +151,6 @@ if __name__ == "__main__":
client = InfluxDBClient(url=url, token=token)
# step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里
influxdb_api.query_pg_scada_info_realtime('bb')
influxdb_api.query_pg_scada_info_realtime(project_info.name)
# 自动执行
realtime_task()