从python的子进程连续调用shell命令并解析输出[重复]

Question

我正在开发一个嵌入式应用程序，它使用来自CANBOAT 存储库的一些预编译二进制文件。

有两个二进制文件可供使用：

1. actisense-serial
2. analyzer

在 shell 中，需要执行actisense -r /dev/ttyUSB0 | analyzer -json 以从连接到 USB 端口的设备获取信息。上述命令将 JSON 信息转储到 STDOUT。

样本输出：

{"timestamp":"2018-08-30T16:27:23.629Z","prio":2,"src":3,"dst":255,"pgn":128259,"description":"Speed","fields":{"SID":106,"Speed Water Referenced Type":"Paddle wheel"}}

{"timestamp":"2018-08-30T16:27:23.629Z","prio":2,"src":6,"dst":255,"pgn":128259,"description":"Speed","fields":{"SID":106,"Speed Water Referenced Type":"Paddle wheel"}}

上述值一直显示在 STDOUT 上。

我希望在 python 脚本中使用上述 shell 命令来获取 JSON 值，解析它们并将它们保存到数据库中。

最初我想从subprocess.check_output 开始。

我试过了：

import subprocess

if __name_ == "__main__":

     while True:
         value = subprocess.check_output(['actisense-serial -r /ttyUSB0',
                                           '|',
                                           'analyzer -json'],
                                        shell=True)
         print(value)

但是没有可用的输出。我不确定如何将 STDOUT 的输出路由到 check_output。

如何实现这一点，来自 shell 命令的连续 JSON 信息可以被解析并在应用程序中进一步使用？

Answer 1

当您像这样使用Popen 时，您可以将管道传递给stdout 和stderr：

actisense_proc = subprocess.Popen(['actisense-serial', '-r', '/ttyUSB0'], 
                                  stdout=subprocess.PIPE)
analyzer_proc = subprocess.Popen(['analyzer', '-json'], stdin=actisense_proc.stdout,
                                 stdout=subprocess.PIPE, stderr=subprocess.PIPE)
while analyzer_proc.poll() is None:
    print(analyzer_proc.stdout.readline())

还要注意，我没有使用shell=True，而是使用了两个Popen 调用，并将第一个的标准输出通过管道传输到第二个的stdin。

编辑：错过了问题的流媒体部分。已更新，因此它将不断从标准输出管道中读取。这将一直运行到子进程终止。