base.py

from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
from sqlalchemy.orm import sessionmaker, declarative_base

Base = declarative_base()


def create_poll(user: str, password: str, host: str, name: str) -> sessionmaker:

    engine = create_async_engine(
        f"postgresql+asyncpg://{user}:{password}@{host}/{name}",
        future=True
    )

    return sessionmaker(engine, expire_on_commit=False, class_=AsyncSession)