Resultados de la búsqueda a petición "python-asyncio"
Asyncio dos bucles para diferentes tareas de E / S?
Estoy usando el módulo Python3 Asyncio para crear una aplicación de equilibrio de carga. Tengo dos tareas pesadas de IO: Un módulo de sondeo SNMP, que determina el mejor servidor posibleUn módulo "tipo proxy", que equilibra las peticiones al ...
Enviar tareas asincio al bucle que se ejecuta en otro hilo
¿Cómo puedo insertar tareas asincrónicamente para ejecutar en unasyncio evento de bucle que se ejecuta en otro hilo? Mi motivación es admitir cargas de trabajo asincrónicas interactivas en el intérprete. No puedo bloquear el hilo principal ...
¿Cómo detectar un error de escritura en asyncio?
Como un ejemplo simple, considere el equivalente de red de / dev / zero, a continuación. (O de manera más realista, solo un servidor web que envía un archivo grande). Si un cliente se desconecta temprano, obtiene un aluvión de mensajes ...
Hacer múltiples llamadas con asyncio y agregar resultados a un diccionario
Tengo problemas para ajustar mi ventaja alrededor de la biblioteca Asyncio de Python 3. Tengo una lista de códigos postales y estoy tratando de hacer llamadas asíncronas a una API para obtener cada código postal correspondiente de la ciudad y el ...
Burlándose de una llamada asincrónica en Python 3.5
¿Cómo me burlo de una llamada asincrónica de una corutina nativa a otra usandounittest.mock.patch? Actualmente tengo una solución bastante incómoda: class CoroutineMock(MagicMock): def __await__(self, *args, **kwargs): future = Future() ...
Cómo establecer el atributo de clase con await en __init__
¿Cómo puedo definir una clase conawait en el constructor o cuerpo de clase? Por ejemplo lo que quiero: import asyncio # some code class Foo(object): async def __init__(self, settings): self.settings = settings self.pool = await create_pool(dsn) ...
¿Cuándo usar y cuándo no usar Python 3.5 `await`?
Estoy recibiendo el flujo de usarasyncio en Python 3.5 pero no he visto una descripción de qué cosas debería serawaiting y cosas que no debería estar o donde sería insignificante. ¿Debo usar mi mejor criterio en términos de "esta es una operación ...
¿Cuál es la diferencia entre loop.create_task, asyncio.async / allow_future y Task?
Estoy un poco confundido por algunosasyncio funciones Veo que hay BaseEventLoop.create_task(coro) [https://docs.python.org/3/library/asyncio-eventloop.html#asyncio.BaseEventLoop.create_task] función para programar una co-rutina. La documentación ...
¿Cómo agregar una rutina a un bucle asíncio en ejecución?
¿Cómo se puede agregar una nueva rutina a un bucle asíncio en ejecución? Es decir. uno que ya está ejecutando un conjunto de corutinas. Supongo que, como solución alternativa, uno podría esperar a que se completen las rutinas existentes y luego ...
¿Diferencia entre corutina y futuro / tarea en Python 3.5?
Digamos que tenemos una función ficticia: async def foo(arg): result = await some_remote_call(arg) return result.upper() Cuál es la diferencia entre: coros = [] for i in range(5): coros.append(foo(i)) loop = ...