run_all.py 1.3 KB

1234567891011121314151617181920212223242526272829
  1. import subprocess
  2. # 定义要启动的应用及其路径和端口
  3. services = [
  4. ("data_processing/data_operation/data_join.py", 10094),
  5. ("data_processing/data_operation/mysql_to_mongo.py", 10095),
  6. ("data_processing/processing_limit_power/processing_limit_power_by_agcavc.py", 10086),
  7. ("data_processing/processing_limit_power/processing_limit_power_by_machines.py", 10087),
  8. ("data_processing/processing_limit_power/processing_limit_power_by_records.py", 10088),
  9. ("data_processing/processing_limit_power/processing_limit_power_by_statistics_light.py", 10085),
  10. ("data_processing/processing_limit_power/processing_limit_power_by_statistics_wind.py", 10093),
  11. ("evaluation_processing/analysis.py", 10092),
  12. ("evaluation_processing/evaluation_accuracy.py", 10091),
  13. ("models_processing/model_train/model_training_lightgbm.py", 10089),
  14. ("models_processing/model_predict/model_prediction_lightgbm.py", 10090),
  15. ("models_processing/model_train/model_training_lstm.py", 10096),
  16. ("models_processing/model_predict/model_prediction_lstm.py", 10097),
  17. ]
  18. # 启动所有服务
  19. processes = []
  20. for service, port in services:
  21. print(f"Starting {service} on port {port}")
  22. p = subprocess.Popen(["python", service])
  23. processes.append(p)
  24. # 等待所有进程结束
  25. for p in processes:
  26. p.wait()