Python实现Oracle操作并实时输出子命令执行过程遇死锁问题

你的代码出现死锁主要有两个核心问题：

1. 忽略标准错误流（stderr）：sqlplus执行过程中会向stderr输出状态或错误信息，若只读取stdout，当stderr管道缓冲区被填满时，sqlplus进程会被阻塞，无法继续处理后续输入，直接导致程序卡死。
2. 错误的输出读取逻辑：sqlplus在交互模式下不会主动输出EOF，iter(proc.stdout.readline,'')会一直等待下一行输出，永远无法退出循环，形成死锁。

另外注意：你的命令里audit_trial是拼写错误，正确参数名应为audit_trail，否则alter system命令会执行失败。

修复后的代码示例 #

import subprocess
import threading

def realtime_output_reader(stream, stream_label):
    """实时读取并打印输出流内容"""
    for line in iter(stream.readline, b''):
        print(f"[{stream_label}] {line.decode('utf-8', errors='ignore').strip()}")
    stream.close()

# 修正参数拼写，添加必要的scope参数与退出命令
cmd_sequence = [
    "show parameter audit;\n",
    "alter system set audit_trail=FALSE scope=spfile;\n",  # scope=spfile保证重启后生效
    "shutdown immediate;\n",
    "startup;\n",
    "exit;\n"  # 主动退出sqlplus会话，避免进程挂起
]

# 启动sqlplus进程，配置行缓冲保证实时输出
oracle_proc = subprocess.Popen(
    "sqlplus / as sysdba",
    shell=True,
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE,
    stderr=subprocess.PIPE,
    bufsize=1,  # 行缓冲模式
    universal_newlines=False  # 字节模式读取，兼容更多编码场景
)

# 启动双线程分别处理stdout和stderr，避免管道阻塞
stdout_thread = threading.Thread(target=realtime_output_reader, args=(oracle_proc.stdout, "STDOUT"))
stderr_thread = threading.Thread(target=realtime_output_reader, args=(oracle_proc.stderr, "STDERR"))
stdout_thread.start()
stderr_thread.start()

# 批量发送命令到sqlplus
for cmd in cmd_sequence:
    oracle_proc.stdin.write(cmd.encode('utf-8'))
    oracle_proc.stdin.flush()

# 关闭输入管道，等待进程执行完成
oracle_proc.stdin.close()
oracle_proc.wait()

# 等待输出处理线程结束
stdout_thread.join()
stderr_thread.join()

关键修改说明 #

• 双线程处理输出：同时监听stdout和stderr，彻底避免单管道阻塞导致的死锁问题。
• 添加exit命令：主动终止sqlplus交互会话，防止进程一直处于等待输入的挂起状态。
• 行缓冲配置：bufsize=1让输出按行实时刷新，满足你"每步过程实时输出"的需求。
• 参数拼写修正：将audit_trial改为audit_trail，保证alter system命令可正常执行。

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