### 执行带有来自人类输入的命令并流式处理结果 为了实现这一目标，可以利用 `subprocess` 模块中的 `Popen` 类来启动子进程，并通过管道传递命令以及获取实时输出。下面是一个详细的例子说明如何结合用户输入执行命令并将结果逐行显示给用户。 #### 获取用户输入 Python 提供了内置函数 `input()` 来接收用户的键盘输入[^1]： ```python command = input("请输入要执行的命令: ") ``` 这行代码会等待用户输入一条命令字符串。 #### 创建子进程并捕获输出 使用 `subprocess.Popen` 可以创建一个新的进程去执行这条命令，并设置标准输出为管道形式以便读取返回的数据： ```python import subprocess def run_command(command): process = subprocess.Popen( command, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, shell=True, text=True ) while True: output = process.stdout.readline() if output == '' and process.poll() is not None: break if output: print(output.strip()) rc = process.poll() return rc ``` 这段代码定义了一个名为 `run_command` 的函数，它接受一个参数作为待执行的命令串。该函数内部调用了 `subprocess.Popen` 方法来启动新进程，并指定了几个重要选项： - `stdout=subprocess.PIPE`: 将子进程的标准输出重定向到父进程中； - `stderr=subprocess.STDOUT`: 把错误信息也导向同一个地方； - `shell=True`: 表明传入的是完整的 Shell 命令而非单独的可执行文件路径加上参数列表； - `text=True`: 设置此标志可以让 Popen 返回解码后的 Unicode 字符串而不是字节序列。 接着进入循环不断尝试从子进程的标准输出中读取数据直到结束为止。每次成功读取一行就立即打印出来，从而实现了所谓的“流式”效果——即随着命令被执行而逐步展示其产生的每一行输出。 最后，在所有输出都被消费完毕之后，检查进程的状态并通过 `poll()` 方法获得退出状态码。 #### 完整示例 将上述两部分结合起来形成一个简单的应用程序框架如下所示： ```python if __name__ == "__main__": user_input = input("请输入要执行的命令: ") exit_code = run_command(user_input) print(f"\n命令已终止，退出状态码：{exit_code}") ``` 这个脚本首先提示用户输入想要执行的具体命令，随后调用之前定义好的 `run_command` 函数来进行实际操作，最终报告整个过程结束后得到的状态码。