FastAPI : comment gérer la connexion à la base de données par requête ?

asked 2 months ago416 viewsfr

7

Avec FastAPI + SQLAlchemy, où créer la session de base de données ? Une globale ? Une par requête ?

AI diagnosis

AI-generated. Not an answer — the community below confirms or corrects it. Always verify before relying on it.

1 Answer

3
✓
✓ Accepted answer

Une session par requête, fournie par une dépendance avec yield. L'engine (le pool de connexions), lui, est créé une seule fois au démarrage.

from sqlalchemy.ext.asyncio import create_async_engine, async_sessionmaker, AsyncSession
from fastapi import Depends, FastAPI

engine = create_async_engine(DATABASE_URL, pool_size=10, pool_pre_ping=True)
SessionLocal = async_sessionmaker(engine, expire_on_commit=False)

async def get_db():
    async with SessionLocal() as session:
        yield session

app = FastAPI()

@app.get('/users/{uid}')
async def get_user(uid: int, db: AsyncSession = Depends(get_db)):
    return await db.get(User, uid)

Le bloc async with garantit la fermeture de la session même en cas d'exception. Ne partage jamais une session entre requêtes concurrentes : elle n'est pas thread/task-safe.

Sign in to tell others whether this worked.

answered 2 months ago

Sign in and verify your email to post an answer.