在 python 的循环中使用 stdout 和 stdin 导致错误

Question

我正在使用标准输出和标准输入在两个 python 程序之间传递信息。 tester.py 应该将遥测数据传递到 helper.py 并且 helper.py 应该 return 一些命令到 tester.py.

这似乎在运行没有循环的情况下有效，但是当我将 tester.py 中的代码放在更新遥测数据的循环中时，helper.py 似乎不再能够传回正确的命令。控制台打印如下：

b'\x00\x00\x00\x00\x01\x00\x00\x00'
0.0
b''
Traceback (most recent call last):
  File "/Users/Advay/Documents/PyCharm/zip_sim/tester.py", line 44, in <module>
    varr = COMMAND_STRUCT.unpack(cmd)
struct.error: unpack requires a buffer of 8 bytes

tester.py:

import sys
import subprocess
import struct

TELEMETRY_STRUCT = struct.Struct(">fB3s")
COMMAND_STRUCT = struct.Struct(">fB3s")
helper = subprocess.Popen(['python3', 'helper.py'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)

drop = 1
padding = bytes(3)

for i in range(5):

    speed = i

    helper.stdin.write(TELEMETRY_STRUCT.pack(speed, drop, padding))
    helper.stdin.flush()

    cmd = helper.stdout.read(COMMAND_STRUCT.size)
    print(cmd)
    varr = COMMAND_STRUCT.unpack(cmd)
    print(varr[0])

和 helper.py:

import os
import random
import sys
import struct

TELEMETRY_STRUCT = struct.Struct(">fB3s")
COMMAND_STRUCT = struct.Struct(">fB3s")

telemetry = sys.stdin.buffer.read(TELEMETRY_STRUCT.size)
a = TELEMETRY_STRUCT.unpack(telemetry)

command = COMMAND_STRUCT.pack(a[0], 1, bytes(3))

sys.stdout.buffer.write(command)
sys.stdout.buffer.flush()

非常感谢任何帮助，我完全不知道为什么会这样。在循环中不起作用。

Answer 1

您正在尝试将多个命令从 tester.py 发送到 helper.py，但 helper.py 仅读取一个命令然后退出 - 没有允许它的循环继续接收来自 tester.py.

的其他命令

当你运行tester.py时，第一次循环迭代成功，但是后面的迭代失败，因为helper.stdout.read()returns一个空值（因为helper已经退出).

您需要构造 helper.py 以便它可以接收多个命令。

例如：

import os
import random
import sys
import struct

TELEMETRY_STRUCT = struct.Struct(">fB3s")
COMMAND_STRUCT = struct.Struct(">fB3s")

while True:
    telemetry = sys.stdin.buffer.read(TELEMETRY_STRUCT.size)
    if not telemetry:
        break

    a = TELEMETRY_STRUCT.unpack(telemetry)

    command = COMMAND_STRUCT.pack(a[0], 1, bytes(3))

    sys.stdout.buffer.write(command)
    sys.stdout.buffer.flush()

通过此更改，运行ning tester.py 导致：

b'\x00\x00\x00\x00\x01\x00\x00\x00'
0.0
b'?\x80\x00\x00\x01\x00\x00\x00'
1.0
b'@\x00\x00\x00\x01\x00\x00\x00'
2.0
b'@@\x00\x00\x01\x00\x00\x00'
3.0
b'@\x80\x00\x00\x01\x00\x00\x00'
4.0

在 python 的循环中使用 stdout 和 stdin 导致错误

Using stdout and stdin in a loop in python leading to errors

python

struct

subprocess

sys