Tag: PYTHON-ASYNCIO
Estoy intentando consultar periódicamente una API. La estructura de mi código es la siguiente: async def QueryData(): print(datetime.datetime.now()) async def main(): await TestApiConnection() scheduler = AsyncIOScheduler(timezone="Europe/Berlin") scheduler.add_job(QueryData, 'cron', minute='0-59') scheduler.start() try: asyncio.get_event_loop().run_forever() except (KeyboardInterrupt, SystemExit): pass scheduler.shutdown(wait=False) if name == "main": asyncio.run(main()) Se produce el siguiente error si ejecuto esto: . . . Read more
Necesito programar una llamada de función periódica en python (es decir, llamada cada minuto), sin bloquear el bucle de eventos (estoy usando el marco Quart con asyncio). Básicamente, necesito enviar tareas al bucle de eventos, con un temporizador, para que el servidor web siga sirviendo las solicitudes entrantes en el . . . Read more
En mi caso de uso, necesito obtener datos de un servidor remoto. El código es aproximadamente equivalente a: def obtener_datos_de_usuario(id_de_usuario): time.sleep(5) … return data df = pd.DataFrame({‘id_de_usuario’: [‘uid1’, ‘uid2’, ‘uid3’, …, ‘uid9999’]}) respuesta = df[‘id_de_usuario’].apply(obtener_datos_de_usuario) Me parece que pandas podría estar ejecutando la función obtener_datos_de_usuario de forma asíncrona. Nota: Ya . . . Read more
No soy realmente un experto de Python, así que disculpen si esto es muy obvio. Estoy tratando de ejecutar un script utilizando asyncio. Aspectos relevantes del código: import websockets import asyncio stream = websockets.connect(<resource_uri>) async def main(): async with stream as receiver: while True: data = receiver.recv() # hacer cosas . . . Read more
Tengo la siguiente función para llamar a s(c) cada 24 horas. def schedule_next_sync(): t = datetime.datetime.now() t = t.replace(hour=0) + datetime.timedelta(hours=24) def wrapper(): s(c) schedule_next_sync() tornado.ioloop.IOLoop.current().add_timeout(datetime.datetime.timestamp(t), wrapper) Sin embargo, s() será cambiado por una función asíncrona. async def s(c): ¿Cómo actualizar schedule_next_sync para la función asíncrona? ¿Debería ejecutar s() de . . . Read more