diff options
author | Victor Stinner <victor.stinner@gmail.com> | 2014-02-03 23:26:28 +0100 |
---|---|---|
committer | Victor Stinner <victor.stinner@gmail.com> | 2014-02-03 23:26:28 +0100 |
commit | c236567ac0f4e15d1c9c493f3d0d524108e3f42b (patch) | |
tree | bf32f7b6c1966d17fa0ac78efc5af0d9647c6c89 /Doc/library/asyncio-subprocess.rst | |
parent | aaa23d69fa66aad0b0a8669a79ec3f498b4ffa81 (diff) | |
download | cpython-c236567ac0f4e15d1c9c493f3d0d524108e3f42b.tar.gz |
asyncio doc: add an example of asyncio.subprocess with communicate() and wait()
Diffstat (limited to 'Doc/library/asyncio-subprocess.rst')
-rw-r--r-- | Doc/library/asyncio-subprocess.rst | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/Doc/library/asyncio-subprocess.rst b/Doc/library/asyncio-subprocess.rst index 5bfbbc7459..3d176f100d 100644 --- a/Doc/library/asyncio-subprocess.rst +++ b/Doc/library/asyncio-subprocess.rst @@ -138,3 +138,43 @@ Process Wait for child process to terminate. Set and return :attr:`returncode` attribute. + +Example +------- + +Implement a function similar to :func:`subprocess.getstatusoutput`, except that +it does not use a shell. Get the output of the "python -m platform" command and +display the output:: + + import asyncio + import sys + from asyncio import subprocess + + @asyncio.coroutine + def getstatusoutput(*args): + proc = yield from asyncio.create_subprocess_exec( + *args, + stdout=subprocess.PIPE, + stderr=subprocess.STDOUT) + try: + stdout, _ = yield from proc.communicate() + except: + proc.kill() + yield from proc.wait() + raise + exitcode = yield from proc.wait() + return (exitcode, stdout) + + loop = asyncio.get_event_loop() + coro = getstatusoutput(sys.executable, '-m', 'platform') + exitcode, stdout = loop.run_until_complete(coro) + if not exitcode: + stdout = stdout.decode('ascii').rstrip() + print("Platform: %s" % stdout) + else: + print("Python failed with exit code %s:" % exitcode) + sys.stdout.flush() + sys.stdout.buffer.flush() + sys.stdout.buffer.write(stdout) + sys.stdout.buffer.flush() + loop.close() |