从subprocess.Popen异步读取stdout

import asyncio
import subprocess

async def read_stdout(process):
    while True:
        line = await process.stdout.readline()
        if not line:
            break
        print(line.decode('utf-8').strip())

async def main():
    process = await asyncio.create_subprocess_shell(
        'ping -c 5 www.google.com',
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE,
    )

    await asyncio.wait([
        read_stdout(process),
        process.wait()
    ])

asyncio.run(main())