我有一个Python脚本,需要发出许多shell命令。我以为我可以创建一个子流程对象,然后在每次执行命令时都重复使用它。
这是我设置代码的方式:
def setupPipeline(self):
setupShell = subprocess.Popen([''], stdout=subprocess.PIPE, shell=True, stderr=subprocess.PIPE, stdin=subprocess.PIPE)
# Stop running pipeline
setupShell.stdin.write('stop ' + self.Name)
output = setupShell.stdout.read()
print output
# Cancel any running jobs and cleanup variables
setupShell.stdin.write('sudo -u pr cancel ALL')
output = setupShell.stdout.read()
print output
setupShell.stdin.write('sudo -u pr clean ALL')
output = setupShell.stdout.read()
print output
(在这里跳过很多其他代码)
if __name__ == '__main__':
#self-test code
pipelineObj = Pipeline(sys.argv)
pipelineObj.setupPipeline()
但是,当代码到达第二个命令时,我得到了一个
IOError: [Errno 32] Broken pipe
我该如何重用子流程对象来发出需要全部在同一shell中执行的命令?这些命令不能简单地链接在一起,因为每个调用之间都在进行处理。
最佳答案
创建一个执行外壳程序的子进程,然后向其发送命令。您正在外壳程序中运行一个空命令,这将使其执行该空命令,然后退出。
shell = subprocess.Popen("/bin/bash -i".split(), stdin=subprocess.PIPE,
stdout=subprocess.PIPE, stderr=subprocess.PIPE)
您可能会考虑使用
pexpect
,因为听起来好像您已经在重新发明它。