How do I create async SQLAlchemy models?

How do I create async SQLAlchemy models?

To create async SQLAlchemy models, you need to use the AsyncSession and declarative_base from SQLAlchemy. Here's a basic example.

Can you show me a code example?

Sure! Here's a simple model:

from sqlalchemy.ext.asyncio import AsyncSession, create_async_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String

Base = declarative_base()

class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String)

engine = create_async_engine('postgresql+asyncpg://user:password@localhost/dbname')

What about querying these models?

You can use AsyncSession to query your models asynchronously. Here's an example:

async with AsyncSession(engine) as session:
    async with session.begin():
        result = await session.execute(select(User))
        users = result.scalars().all()