使用子进程PIPE在Python脚本之间发送字符串

Question

我想在我的主Python程序中使用subprocess打开一个Python脚本。我希望这两个程序都在运行时能够相互聊天，这样我就可以监视从脚本中的活动，也就是说，我需要它们在彼此之间发送字符串。

主程序将具有与此类似的功能，该功能将与从属脚本通信并监控从属脚本：

脚本1

import subprocess
import pickle
import sys
import time
import os

def communicate(clock_speed, channel_number, frequency):
    p = subprocess.Popen(['C:\\Python27\\pythonw','test.py'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)
    data = pickle.dumps([clock_speed, channel_number, frequency]).replace("\n", "\\()")
    print data
    p.stdin.write("Start\n")
    print p.stdout.read()
    p.stdin.write(data + "\n")
    p.poll()
    print p.stdout.readline()
    print "return:" + p.stdout.readline()
    #p.kill()

if __name__ == '__main__':
    print "GO"
    communicate(clock_speed = 400, channel_number = 0, frequency = 5*1e6)

测试。py脚本与此类似：

脚本2

import ctypes
import pickle
import time
import sys

start = raw_input("")
sys.stdout.write("Ready For Data")
data = raw_input("")
data = pickle.loads(data.replace("\\()", "\n"))
sys.stdout.write(str(data))
###BUNCH OF OTHER STUFF###

我希望这些脚本执行以下操作：

1. 脚本1使用Popen打开脚本2
2. 脚本1发送字符串开始\n
3. 脚本2读取这个字符串，并发送字符串准备数据
4. 脚本1读取这个字符串，并将提取的数据发送到脚本2
5. 然后无论...

主要问题是如何做第2-4部分。然后两个脚本之间的其余通信应该遵循。到目前为止，我只能在脚本2终止后读取它的字符串。

任何帮助都非常感谢。

更新：

脚本1必须使用32位Python运行，而脚本2必须使用64位Python运行。

Answer 1

我也遇到了类似的问题，在不同进程之间发送一般Python对象时，如果不知道另一方何时没有发送对象或对象何时关闭，就无法实现。还尝试使用多处理。队列通常意味着流程需要由当前流程启动，而这在两个流程想要协作时并不总是如此。

为了解决这个问题，我使用了picklepipe模块，它定义了一个通用的对象序列化管道接口，以及一个使用pickle协议（称为picklepipe）的管道（也是一个使用MarshalPipe协议的管道）。它可以发送的不仅仅是字符串，它还可以将任何可pickle对象发送给它的对等对象。

管道甚至可以选择，这意味着当准备接收新对象时，选择器模块（或选择器2，选择器34）可以将管道用作文件对象。这使得等待许多不同管道准备就绪非常有效。

支持Python 2.7（可能还有2.6）和所有主要平台。甚至可以在两个不同版本的Python之间发送对象！查看项目文档或在Github上查看源代码。

披露：我是泡菜管的作者。我很乐意听到你的反馈。：）

Answer 2

管道的问题是，如果您调用读取操作而没有任何内容可读取，那么您的代码将被暂停，直到另一方为您写入要读取的内容为止。此外，如果您写得太多，您的下一个写操作可能会阻塞，直到另一方从管道中读取某些内容并释放它。

您可以进行“非阻塞调用”，在这些情况下会返回错误，而不是阻塞，但您的html" target="_blank">应用程序仍需要明智地处理错误。

在任何情况下，您都需要设置某种协议。想想HTTP，或者你熟悉的任何其他协议：有请求和响应，当你阅读这两个协议中的任何一个时，协议总是告诉你是否还有其他需要阅读的内容。这样，您就可以随时做出是否等待更多数据的明智决定。

这里有一个有效的例子。它的工作原理是因为有以下协议：

• p1发送一行，以“\n”结尾
• p2也是如此
• p1发送另一条线路
• p2也是如此
• 两人都很开心，都退出了

为了给管道写一行（在任何一边）并确保它到达管道上，我调用写（），然后调用flush（）。

为了从管道（任一侧）读取一行数据，但不超过一个字节，从而阻塞代码，直到该行准备就绪，并且不再超过该行，我使用readline（）。

您还可以进行其他呼叫和其他协议，包括现成的协议，但是单行协议对于简单的事情和像这样的演示非常有效。

p1。py:

import subprocess

p = subprocess.Popen(['python', 'p2.py'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)
p.stdin.write("Hello\n")
p.stdin.flush()
print 'got', p.stdout.readline().strip()
p.stdin.write("How are you?\n")
p.stdin.flush()
print 'got', p.stdout.readline().strip()

p2.py：

import sys

data = sys.stdin.readline()
sys.stdout.write("Hm.\n")
sys.stdout.flush()
data = sys.stdin.readline()
sys.stdout.write("Whatever.\n")
sys.stdout.flush()