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

Question

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

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.

```python
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.

1 réponse