Python多进程（multiprocessing）超时处理方案咨询

Hey Kevin, let's tackle this timeout issue with your SAP report pulling processes! I know you've tried looking up related questions but haven't found a fit for your Windows + multiprocessing + scheduled task scenario, so here's a tailored solution you can use directly without heavy code modifications.

核心思路 #

Since Windows doesn't support signal.alarm, we'll use multiprocessing.Process's built-in join(timeout) method to control execution time. When a process exceeds the set timeout, we'll actively terminate it and ensure clean resource handling.

可直接复用的代码实现 #

import multiprocessing
import time
# 替换成你实际调用SAP拉取报表的模块/函数
from your_sap_script import pull_sap_report  

def sap_task_wrapper(task_info):
    """封装SAP报表拉取逻辑，增加异常捕获"""
    report_name, report_params = task_info
    try:
        print(f"开始拉取报表: {report_name}")
        pull_sap_report(report_name, report_params)
        print(f"报表 {report_name} 拉取完成")
    except Exception as e:
        print(f"报表 {report_name} 拉取出错: {str(e)}")

def run_process_with_timeout(process, timeout_sec):
    """带超时控制的进程执行函数"""
    process.start()
    # 等待进程执行，超时则强制终止
    process.join(timeout_sec)
    if process.is_alive():
        print(f"进程 {process.pid} (对应报表任务) 超时，正在终止...")
        process.terminate()
        process.join()  # 等待进程彻底退出
        print(f"进程 {process.pid} 已成功终止")

if __name__ == "__main__":
    # 模拟你的多个SAP报表任务列表
    sap_report_tasks = [
        ("销售日报表", {"区域": "华东", "日期": "今日"}),
        ("库存统计表", {"仓库": "主仓", "类型": "原材料"}),
        # 可添加更多任务...
    ]

    # 每5分钟执行一轮任务的主循环
    while True:
        print("\n=== 启动新一轮SAP报表拉取任务 ===")
        process_list = []
        # 为每个任务创建进程
        for task in sap_report_tasks:
            proc = multiprocessing.Process(target=sap_task_wrapper, args=(task,))
            process_list.append(proc)
        
        # 给每个进程设置超时（建议设为4.5分钟，给定时任务留缓冲）
        timeout = 4.5 * 60  # 270秒
        for proc in process_list:
            run_process_with_timeout(proc, timeout)
        
        print("=== 本轮任务执行完毕，等待5分钟后继续 ===")
        time.sleep(5 * 60)  # 5分钟定时等待

关键细节说明 #

• 超时时间设置：设为比5分钟定时稍短（比如4.5分钟），避免定时任务触发时还有未终止的进程残留，导致资源占用。
• 进程清理：process.terminate()会强制终止进程，如果你的SAP拉取涉及GUI窗口，建议在pull_sap_report里增加窗口关闭的逻辑（比如调用SAP自带的API），避免残留无效窗口。
• 异常捕获：在sap_task_wrapper里捕获异常，能及时反馈任务执行中的错误，而不是让进程默默卡住。

内容的提问来源于stack exchange，提问作者Kevin