Estoy tratando de crear una aplicación usando FastAPI + uvicorn.
Esta aplicación debe poder manejar conexiones simultáneas. No puedo garantizar que todo el código se pueda ejecutar de forma asíncrona/en espera.
Luego, pensé en usar las opciones --workers X de uvicorn para manejar conexiones simultáneas, pero necesito compartir la misma conexión de base de datos entre todos los trabajadores.
Probé el siguiente ejemplo:
import time from pymongo.database import Database from fastapi import Depends, FastAPI from dynaconf import settings from pymongo import MongoClient print("-------> Creating a new MongoDB connection") db_conn = MongoClient(settings.MONGODB_URI) db = db_conn.get_database('mydb') app = FastAPI() def get_db(): return db @app.get("/{id}") async def main(id: str, db: Database = Depends(get_db)): print("Recebido id: " + id) time.sleep(10) return { 'id': id } $uvicorn main:app --workers 2 INFO: Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit) INFO: Started parent process [24730] -------> Creating a new MongoDB connection -------> Creating a new MongoDB connection INFO: Started server process [24733] INFO: Waiting for application startup. INFO: Application startup complete. INFO: Started server process [24732] INFO: Waiting for application startup. INFO: Application startup complete.Pero estoy recibiendo dos conexiones mongodb.
¿Cómo puedo compartir la conexión MongoDB y evitar crear una conexión para cada trabajador?
No debe compartir la conexión, ya que tiene estado. Dos o más procesos no pudieron usar una sola conexión de socket con éxito.