9 lines
350 B
Python
9 lines
350 B
Python
|
"""Async database sessions; each request and background operation owns its transaction."""
|
||
|
|
|
||
|
|
from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine
|
||
|
|
|
||
|
|
|
||
|
|
def create_database(url: str):
|
||
|
|
engine = create_async_engine(url, pool_pre_ping=True, hide_parameters=True)
|
||
|
|
return engine, async_sessionmaker(engine, expire_on_commit=False)
|