Desarrollo de Python
  1. Desarrollo de Python
  3. aysncio no puede leer stdin en Windows
Intereting Posts
Creación del modelo Django a partir de bases de datos MongoDB existentes. Cómo establecer variables de entorno en el servicio Supervisor Establecer dinámicamente la variable local Cifrado y descifrado RSA en Python Mejorar la calidad de la conversión de varita Conjunto de Python con la habilidad de reventar un elemento aleatorio En Python, ¿cómo creo una cadena de n caracteres en una línea de código? Pruebas unitarias continuas con Pydev (Python y Eclipse) ¿Cómo limpiar el entorno iPython para que pueda comenzar de nuevo con Jupyter y Python 3.x? pandas fusionando marcos de datos en un bucle ¿Cómo funciona la resolución e invocación del método internamente en Python? segmentación del dataframe para las filas que contienen ‘.’ usando pandas Python bug con __le__, __ge__? ¿Cómo verificar si todos los elementos en una tupla o lista están en otra? BeautifulSoup: Obtener el contenido de una tabla específica

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.