0
608
VistasEjecutar hilo de fondo infinito separado en una aplicación web de python (fastapi/flask/django)
¿Cómo puedo iniciar una aplicación que hace las siguientes 2 cosas?
- Exponga el punto final de descanso a través de FastAPI.
- Ejecute un subproceso separado infinitamente ( rabbitmq consumidor - pika ) esperando la solicitud.
A continuación se muestra el código a través del cual estoy lanzando el servidor fastAPI. Pero cuando trato de ejecutar un hilo, antes de la ejecución de la siguiente línea, dice que nunca se esperó la corrutina.
¿Cómo se pueden ejecutar ambos en paralelo?
·
Santiago Trujillo
2 Respuestas
Responde la pregunta0
Tal vez esta no sea la respuesta que buscas. Hay una biblioteca llamada celery que hace que los subprocesos múltiples sean fáciles de administrar en python.
Échale un vistazo: https://docs.celeryproject.org/en/stable/getting-started/introduction.html
·
Santiago Trujillo
Denunciar
0
import asyncio from concurrent.futures import ThreadPoolExecutor from fastapi import FastAPI import uvicorn app = FastAPI() def run(corofn, *args): loop = asyncio.new_event_loop() try: coro = corofn(*args) asyncio.set_event_loop(loop) return loop.run_until_complete(coro) finally: loop.close() async def sleep_forever(): await asyncio.sleep(1000) # async def main(): loop = asyncio.get_event_loop() executor = ThreadPoolExecutor(max_workers=2) futures = [loop.run_in_executor(executor, run, sleep_forever), loop.run_in_executor(executor, run, uvicorn.run, app)] print(await asyncio.gather(*futures)) if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(main())Nota: Esto puede dificultar el rendimiento de FastAPI. Un mejor enfoque sería usar una tarea de apio
·
Santiago Trujillo
Denunciar
Responde la pregunta