Desarrollo de Python
  1. Desarrollo de Python
  3. aysncio no puede leer stdin en Windows
Intereting Posts
ValueError: tipo de url desconocido en urllib2, aunque la url está bien si se abre en un navegador Error de Python3: initial_value debe ser str o None Ningún módulo llamado ‘win32api’ Py2exe para Python 3.0 Pandas: selecciona el primer par de filas en cada grupo ¿Cuál es el papel de npartitions en un dataframe de Dask? matriz numpy rebanar resultados inesperados ¿Cómo uso un botón para cambiar entre dos gráficos diferentes en matplotlib? Embalaje Python: ruedas vs tarball (tar.gz) Extensión Python C: ¿Usar extensión PYD o DLL? ¿Cómo instalo un paquete de Python con un archivo .whl? Python Cómo obtener valores que están en un dataframe pero no en un segundo Cómo ejecutar el código después de Flask send_file () o send_from_directory () Pon un símbolo antes y después de cada carácter en una cadena. Registro de Python: ¿Por qué se llama dos veces a __init__?

aysncio no puede leer stdin en Windows

Estoy tratando de leer stdin de forma asíncrona en Windows 7 de 64 bits y Python 3.4.3

Intenté esto inspirado por una respuesta 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()

Sin embargo, genera un OSError: [WInError 100381] An operation was attempted on something that is not a socket .

¿Podría un objeto similar a un archivo como stdin ser envuelto en una clase para darle la API de un socket? He hecho esta pregunta por separado , pero si la solución es simple, responda aquí.

Suponiendo que no puedo envolver un objeto similar a un archivo para convertirlo en un socket, intenté usar flujos inspirados en esta esencia : 

 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()

Y eso genera un NotImplementedError en asyncio.base_events._make_read_pipe_transport

Por favor avise cómo leer stdin usando asyncio en Windows …

La excepción NotImplementedError se NotImplementedError porque las líneas de conexión de tuberías no son compatibles con SelectorEventLoop , que es el bucle de eventos predeterminado establecido en asyncio . ProactorEventLoop usar un ProactorEventLoop para admitir tuberías en Windows. Sin embargo, aún no funcionaría porque aparentemente las funciones connect_read_pipe y connect_write_pipe no admiten stdin / stdout / stderr o archivos en Windows como Python 3.5.1.

Una forma de leer desde stdin con un comportamiento asíncrono es usar un hilo con el método run_in_executor del bucle. Aquí hay un ejemplo simple para referencia: 

 import asyncio import sys async def aio_readline(loop): while True: line = await loop.run_in_executor(None, sys.stdin.readline) print('Got line:', line, end='') loop = asyncio.get_event_loop() loop.run_until_complete(aio_readline(loop)) loop.close()

En el ejemplo, la función sys.stdin.readline() es llamada dentro de otro hilo por el método loop.run_in_executor . El hilo permanece bloqueado hasta que stdin recibe un salto de línea, mientras tanto, el bucle es libre de ejecutar otras rutinas si existieran.