python - 如何使用 asyncio 从子进程流式传输 stdout/stderr，并在之后获取其退出代码？

Question

在 Windows 上的 Python 3.4 下，我需要流式传输子进程写入 stdout/stderr 的数据，即使用 asyncio 接收它的输出。 Python 3.4 中引入的框架。之后我还必须确定程序的退出代码。我该怎么做？

Answer 1

到目前为止我提出的解决方案使用 SubprocessProtocol接收来自子进程的输出，以及相关联的传输以获取进程的退出代码。我不知道这是否是最佳的。我的方法基于 answer to a similar question by J.F. Sebastian .

import asyncio
import contextlib
import os
import locale


class SubprocessProtocol(asyncio.SubprocessProtocol):
    def pipe_data_received(self, fd, data):
        if fd == 1:
            name = 'stdout'
        elif fd == 2:
            name = 'stderr'
        text = data.decode(locale.getpreferredencoding(False))
        print('Received from {}: {}'.format(name, text.strip()))

    def process_exited(self):
        loop.stop()


if os.name == 'nt':
    # On Windows, the ProactorEventLoop is necessary to listen on pipes
    loop = asyncio.ProactorEventLoop()
    asyncio.set_event_loop(loop)
else:
    loop = asyncio.get_event_loop()
with contextlib.closing(loop):
    # This will only connect to the process
    transport = loop.run_until_complete(loop.subprocess_exec(
        SubprocessProtocol, 'python', '-c', 'print(\'Hello async world!\')'))[0]
    # Wait until process has finished
    loop.run_forever()
    print('Program exited with: {}'.format(transport.get_returncode()))