How can I use FastAPI with an async ORM?

How can I use FastAPI with an async ORM?

You can use FastAPI with async ORMs like SQLAlchemy or Tortoise-ORM. Would you like a code example?

Yes, please provide a code example using SQLAlchemy.

Sure! Here's a simple example:

from fastapi import FastAPI
from sqlalchemy.ext.asyncio import AsyncSession, create_async_engine
from sqlalchemy.orm import sessionmaker

DATABASE_URL = "postgresql+asyncpg://user:password@localhost/dbname"
engine = create_async_engine(DATABASE_URL, echo=True)
AsyncSessionLocal = sessionmaker(bind=engine, class_=AsyncSession, expire_on_commit=False)

app = FastAPI()

@app.get("/items/{item_id}")
async def read_item(item_id: int):
    async with AsyncSessionLocal() as session:
        result = await session.execute(select(Item).where(Item.id == item_id))
        item = result.scalars().first()
        return item

This sets up an async database session and a simple endpoint.

What if I want to add more endpoints?

You can add more endpoints by defining additional route functions in your FastAPI app. Just follow the same pattern as the read_item function!

Thanks! How do I handle database migrations?

You can use Alembic for handling migrations with SQLAlchemy. It integrates well with async setups.