Asyncio subprocess

import asyncio

async def main():
    process = await asyncio.create_subprocess_shell('ping 8.8.8.8 -c 5', close_fds=True,
        stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)

    while process.returncode is None:
        data = await process.stdout.read(1024)
        if data:
            print(data)
        else:
            await asyncio.sleep(0.001)  # returncode is set after sleep

    print('code', process.returncode)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()

import asyncio

async def main():
    process = await asyncio.create_subprocess_shell('ping 8.8.8.8 -c 5', close_fds=True,
        stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
    returncode = await process.wait()
    data = await process.stdout.read()

    print('code', returncode)
    print('data', data)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()