我试图在Windows 7 64位和Python 3.4.3上异步读取stdin。
我尝试了一个受SO答案启发的方法:
import asyncio
import sys
def reader():
print('Received:', sys.stdin.readline())
loop = asyncio.get_event_loop()
task = loop.add_reader(sys.stdin.fileno(), reader)
loop.run_forever()
loop.close()
然而,它会引发一个OSError: [WInError 100381] An operation was attempted on something that is not a socket
。
像stdin
这样的类似文件对象是否可以被包装在一个类中,使其具有套接字的API?我已经单独提出了这个问题,但如果解决方案很简单,请在此回答。
假设我不能将文件对象包装成套接字,那么我尝试使用流,受到这个代码片段的启发:
import asyncio
import sys
@asyncio.coroutine
def stdio(loop):
reader = asyncio.StreamReader(loop=loop)
reader_protocol = asyncio.StreamReaderProtocol(reader)
yield from loop.connect_read_pipe(lambda: reader_protocol, sys.stdin)
@asyncio.coroutine
def async_input(loop):
reader = yield from stdio(loop)
line = yield from reader.readline()
return line.decode().replace('\r', '').replace('\n', '')
@asyncio.coroutine
def main(loop):
name = yield from async_input(loop)
print('Hello ', name)
loop = asyncio.get_event_loop()
loop.run_until_complete(main(loop))
loop.close()
这会在asyncio.base_events._make_read_pipe_transport
引发一个NotImplementedError
请指导如何在Windows上使用asyncio
读取stdin
...
aio_readline()
是非阻塞的,程序本身通过使用run_until_compete()
来实现阻塞。但是你应该只在你的应用程序中使用await loop.run_in_executor(None, sys.stdin.readline)
部分。其余部分只是为了示范用法。 - Gabriel Cangussu