子进程结束导致PyODBC连接关闭，如何维持父进程连接？

当你用os.fork()创建子进程时，子进程会完整复制父进程的所有文件描述符，包括ODBC连接对应的底层句柄（比如网络套接字）。子进程退出时，系统会自动关闭这些继承来的文件描述符，而ODBC驱动会因为底层资源被释放，判定父进程的连接已失效，从而抛出Invalid cursor state错误。

方案1：子进程启动后立即关闭ODBC资源 #

子进程只需要处理row数据，根本不需要使用ODBC连接。所以fork后，子进程第一时间关闭继承来的游标和连接，避免退出时影响父进程的连接：

修改代码中子进程的逻辑：

elif forked_pid == 0:
    # 子进程不需要连接，立即关闭继承的游标和连接
    curs.close()
    cnx.close()
    processRow(row)
    # 用os._exit正常退出，替代粗暴的SIGINT
    os._exit(0)

同时修正父进程里的子进程回收逻辑（原代码未移除已结束的PID）：

# 修正子进程回收逻辑
temp_pids = []
for pid in PIDS:
    ret_pid, exit_code = os.waitpid(pid, os.WNOHANG)
    if ret_pid == 0:
        # 进程还在运行，保留
        temp_pids.append(pid)
PIDS = temp_pids

方案2：改用multiprocessing.Pool管理进程（推荐） #

手动用os.fork管理进程容易出错，改用Python标准库的multiprocessing.Pool可以自动处理进程创建、资源隔离和回收，默认会避免子进程继承不必要的文件描述符：

import multiprocessing
import pyodbc
import textwrap

def processRow(row):
    # 你的处理逻辑
    pass

def main():
    try:
        cnx = pyodbc.connect('DSN=REDACTED; UID=%s; PWD=%s;' % (some.username, some.password))
    except pyodbc.Error as err:
        # TODO: 添加错误日志
        return
    curs = cnx.cursor()
    
    stmt = textwrap.dedent("""
        SELECT message_data
        FROM TABLE(QSYS2.RECEIVE_DATA_QUEUE(
            DATA_QUEUE => 'MYDTAQ',
            DATA_QUEUE_LIBRARY => 'MYLIB',
            REMOVE => 'YES'
        ))
        """)

    # 创建最多5个进程的进程池
    with multiprocessing.Pool(processes=5) as pool:
        while True:
            curs.execute(stmt)
            row = curs.fetchone()
            if not row:
                break
            # 异步提交任务到进程池
            pool.apply_async(processRow, args=(row,))
        # 等待所有任务完成后关闭池
        pool.close()
        pool.join()
    
    curs.close()
    cnx.close()

if __name__ == "__main__":
    main()

这个方案不需要手动管理PID和waitpid，代码更简洁，也从根源避免了资源继承的问题。

不推荐的方案 #

• 每次读取前打开/关闭连接：频繁建立和断开ODBC连接会带来显著的性能开销，尤其是数据队列记录较多时。
• 一次性读取所有记录：如果程序中途崩溃，未处理的记录会丢失，违背了逐条读取处理的可靠性要求。

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