| from sqlalchemy.ext.asyncio import AsyncSession, create_async_engine | |
| from sqlalchemy.orm import sessionmaker | |
| from .config import settings | |
| engine = create_async_engine(settings.database_url, echo=False) | |
| async_session = sessionmaker(engine, class_=AsyncSession, expire_on_commit=False) | |
| async def get_db(): | |
| async with async_session() as session: | |
| yield session | |