Function asession

reflex/model.py:691–714

Get an async sqlmodel session to interact with the database. async with rx.asession() as asession: ... Most operations against the `asession` must be awaited. Args: url: The database url. Returns: An async database session.

(url: str | None = None)

        return sqlmodel.Session(get_engine(url))

    def asession(url: str | None = None) -> AsyncSession:
        """Get an async sqlmodel session to interact with the database.

        async with rx.asession() as asession:
            ...

        Most operations against the `asession` must be awaited.

        Args:
            url: The database url.

        Returns:
            An async database session.
        """
        global _AsyncSessionLocal
        if url not in _AsyncSessionLocal:
            _AsyncSessionLocal[url] = sqlalchemy.ext.asyncio.async_sessionmaker(
                bind=get_async_engine(url),
                class_=AsyncSession,
                expire_on_commit=False,
                autocommit=False,
                autoflush=False,
            )
        return _AsyncSessionLocal[url]()

else:
    get_db_status = _print_db_not_available