Python subprocess 输出

### 处理 Python `subprocess` 模块的输出 在使用 Python 的 `subprocess` 模块时，可以通过多种方式捕获和处理子进程的标准输出（stdout）、标准错误（stderr）以及返回码。以下是一个详细的说明及其示例。 #### 示例代码：捕获和处理子进程的输出 通过设置参数 `capture_output=True` 和 `text=True`，可以轻松捕获子进程的标准输出和标准错误，并将其作为字符串处理[^2]。 ```python import subprocess # 运行命令并捕获输出 process = subprocess.run( ['echo', 'Hello, Subprocess!'], capture_output=True, text=True ) # 输出结果 print("标准输出:", process.stdout.strip()) # 打印标准输出 if process.stderr: print("标准错误:", process.stderr.strip()) # 如果存在，则打印标准错误 print("返回码:", process.returncode) # 打印返回码 ``` 此代码片段展示了如何运行简单的 shell 命令（如 `echo`），并通过 `subprocess.run()` 方法捕获其输出、错误信息以及返回状态码。 --- #### 动态交互式输入与输出 对于需要动态交互的场景，例如自动化交互式命令行工具，可以使用 `Popen` 类来启动子进程，并通过 `communicate()` 方法传递输入和接收输出[^3]。 ```python import subprocess # 启动一个新的 Python 解释器进程 proc = subprocess.Popen( ["python"], stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True ) # 发送代码到解释器并获取输出 commands = """ print("这是来自子进程的消息!") result = 10 * 5 print(f"计算的结果是: {result}") """ stdout, stderr = proc.communicate(commands) # 显示结果 print("子进程的标准输出:\n", stdout) if stderr: print("子进程的标准错误:\n", stderr) ``` 在此示例中，父进程向子进程中注入了一段 Python 脚本，并成功接收到执行后的输出。 --- #### 并行执行多个命令 为了实现更复杂的任务，比如并行化操作，可以创建多个独立的子进程并分别收集它们的输出[^1]。 ```python import subprocess def run_command(cmd): result = subprocess.run( cmd, capture_output=True, text=True ) return { "cmd": cmd, "stdout": result.stdout.strip(), "stderr": result.stderr.strip() if result.stderr else None, "returncode": result.returncode } # 定义一组要并行执行的任务 tasks = [ ['echo', 'Task A'], ['echo', 'Task B'] ] # 收集所有任务的结果 results = [] for task in tasks: results.append(run_command(task)) # 展示每项任务的输出 for res in results: print(f"Command: {' '.join(res['cmd'])}") print("Output:", res["stdout"]) if res["stderr"]: print("Errors:", res["stderr"]) print("Return Code:", res["returncode"]) print("-" * 40) ``` 这段代码演示了如何定义一系列命令列表，并逐一运行这些命令以获得各自的输出。 --- #### 错误处理机制 当某些外部命令可能失败时，应考虑异常情况下的处理逻辑。例如，在尝试访问不存在目录的情况下，可能会引发 `CalledProcessError` 异常[^5]。 ```python import subprocess try: output = subprocess.check_output(['ls', 'non_existent_dir']) except subprocess.CalledProcessError as e: print(f"命令执行失败: 返回码={e.returncode}, 错误消息={e.output.decode('utf-8')}") else: print("命令成功执行:") print(output.decode('utf-8')) ``` 该例子显示了如何优雅地捕捉因命令失败而产生的异常，并从中提取有用的诊断信息。 --- ### 总结 以上介绍了几种常见的方法用于捕获和处理由 `subprocess` 模块生成的数据流。无论是简单的一次性调用还是复杂的大规模并发作业管理，都可以借助这一强大工具完成高效编程工作。