与一个进程进行多次通信而不破坏管道？

Question

这不是我第一次遇到这个问题，而且它确实困扰着我。 每当我使用 Python subprocess 模块打开管道时，我只能与它通信一次，正如文档指定的那样：从 stdout 和 stderr 读取数据，直到结束-of-file is returned

proc = sub.Popen("psql -h darwin -d main_db".split(),stdin=sub.PIPE,stdout=sub.PIPE)
print proc.communicate("select a,b,result from experiment_1412;\n")[0]
print proc.communicate("select theta,zeta,result from experiment_2099\n")[0]

这里的问题是，第二次，Python 不高兴。事实上，他决定在第一次通信后关闭文件：

Traceback (most recent call last):
File "a.py", line 30, in <module>
    print proc.communicate("select theta,zeta,result from experiment_2099\n")[0]
File "/usr/lib64/python2.5/subprocess.py", line 667, in communicate
    return self._communicate(input)
File "/usr/lib64/python2.5/subprocess.py", line 1124, in _communicate
     self.stdin.flush()
ValueError: I/O operation on closed file

是否允许多次通信？

Answer 1

我认为你误解了沟通...

http://docs.python.org /library/subprocess.html#subprocess.Popen.communicate

communications 发送一个字符串到另一个进程，然后等待它完成...（就像你说的等待 EOF 监听 stdout 和 stderror）

你应该做的是：（

proc.stdin.write('message')

# ...figure out how long or why you need to wait...

proc.stdin.write('message2')

如果你需要获取 stdout 或 stderr，你可以使用 proc.stdout 或 proc.stderr）

Answer 2

我以前遇到过这个问题，据我所知，你不能用 subprocess 来做到这一点（我同意，如果这是真的，那是非常违反直觉的）。我最终使用了 pexpect（可从 PyPI 获得）。

Answer 3

您只需调用一次 communicate() 即可完成此操作：

query1 = 'select a,b,result from experiment_1412;'
query1 = 'select theta,zeta,result from experiment_2099;'
concat_query = "{}\n{}".format(query1, query2)
print(proc.communicate(input=concat_query.encode('utf-8'))[0])

这里的关键点是您只向 stdin 写入一次，并且 \n 作为 EOL。
你的psql子进程从stdin读取直到\n，然后在完成第一个查询后，它再次转到stdin，此时只有第二个查询字符串留在缓冲区中。

Answer 4

您可以使用：

proc.stdin.write('input')    
if proc.stdout.closed:
    print(proc.stdout)