Resultados de la búsqueda a petición "python-asyncio"
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 crear un generador asíncrono en Python?
Estoy tratando de reescribir este código Python2.7 al nuevo orden mundial asíncrono: def get_api_results(func, iterable): pool = multiprocessing.Pool(5) for res in pool.map(func, iterable): yield resmap() bloquea hasta que se hayan ...
usar asyncio para tareas paralelas
Me preguntaba cómo podría usar asyncio para manejar tareas similares a las que hace nodeJS. Quiero ejecutar tareas al mismo tiempo sin abrir hilos. Ejemplo: import asyncio @asyncio.coroutine def my_coroutine(task_name, seconds_to_sleep=3): ...
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) ...
Asyncio decodifica utf-8 con StreamReader
Me estoy acostumbrando a asyncio y encuentro que el manejo de tareas es bastante agradable, pero puede ser difícil mezclar bibliotecas asíncronas con bibliotecas io tradicionales. El problema que estoy enfrentando actualmente es cómo decodificar ...
¿Cómo llamamos a una función normal donde se espera una corutina?
Considere una corutina que llama a otra corutina: async def foo(bar): result = await bar() return resultEsto funciona bien sibar Es una corutina. ¿Qué debo hacer? (Es decir, con qué debo terminar la llamada abar) para que este código haga lo ...
RuntimeError: este bucle de eventos ya se está ejecutando en python
Creo que recibo este error porque mi código llamaasyncio.get_event_loop().run_until_complete(foo()) dos veces. Una vez defoo() y la segunda vez desde la función llamada porfoo(). Mi pregunta es entonces: ¿por qué debería ser esto un problema? ...
¿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 ...
¿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 ...