SQLAlchemy с сбоем asyncpg с ошибкой: asyncpg.InterfaceError – невозможно выполнить операцию: выполняется другая операци ⇐ Python
SQLAlchemy с сбоем asyncpg с ошибкой: asyncpg.InterfaceError – невозможно выполнить операцию: выполняется другая операци
Я разрабатываю сервер fastapi, используя sqlalchemy и asyncpg для работы с базой данных postgres. Для каждого запроса создается новая сессия (через внедрение зависимостей fastapi, как в документации). Я использовал sqlite+aiosqlite до postgres+asyncpg, и все работало отлично. После того, как я переключился с sqlite на postgres, каждый запрос fastapi завершался с ошибкой:
sqlalchemy.dialects.postgresql.asyncpg.InterfaceError — невозможно выполнить операцию: выполняется другая операция Вот как я создаю движок и сеансы:
при вводе генератора импорта импортировать ОС из импорта sqlalchemy create_engine из sqlalchemy.orm импортируйте создателя сеанса, сеанс из sqlalchemy.ext.asyncio импортировать AsyncSession, create_async_engine пользователь = os.getenv('PG_USER') пароль = os.getenv('PG_PASSWORD') домен = os.getenv('PG_DOMAIN') db = os.getenv('PG_DATABASE') # db_async_url = f'sqlite+aiosqlite:///database.sqlite3' db_async_url = f'postgresql+asyncpg://{user}:{пароль}@{domain}/{db}' async_engine = create_async_engine( db_async_url, будущее = Истина, эхо = Истина ) create_async_session = создатель сеанса( async_engine, class_=AsyncSession, expire_on_commit=False ) async def get_async_session() -> Генератор[AsyncSession]: асинхронно с create_async_session() в качестве сеанса: сессия доходности
Я разрабатываю сервер fastapi, используя sqlalchemy и asyncpg для работы с базой данных postgres. Для каждого запроса создается новая сессия (через внедрение зависимостей fastapi, как в документации). Я использовал sqlite+aiosqlite до postgres+asyncpg, и все работало отлично. После того, как я переключился с sqlite на postgres, каждый запрос fastapi завершался с ошибкой:
sqlalchemy.dialects.postgresql.asyncpg.InterfaceError — невозможно выполнить операцию: выполняется другая операция Вот как я создаю движок и сеансы:
при вводе генератора импорта импортировать ОС из импорта sqlalchemy create_engine из sqlalchemy.orm импортируйте создателя сеанса, сеанс из sqlalchemy.ext.asyncio импортировать AsyncSession, create_async_engine пользователь = os.getenv('PG_USER') пароль = os.getenv('PG_PASSWORD') домен = os.getenv('PG_DOMAIN') db = os.getenv('PG_DATABASE') # db_async_url = f'sqlite+aiosqlite:///database.sqlite3' db_async_url = f'postgresql+asyncpg://{user}:{пароль}@{domain}/{db}' async_engine = create_async_engine( db_async_url, будущее = Истина, эхо = Истина ) create_async_session = создатель сеанса( async_engine, class_=AsyncSession, expire_on_commit=False ) async def get_async_session() -> Генератор[AsyncSession]: асинхронно с create_async_session() в качестве сеанса: сессия доходности
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
SQLalchemy с Asyncpg не может выполнять работу: в процессе выполнения другая операция
Anonymous » » в форуме Python - 0 Ответы
- 48 Просмотры
-
Последнее сообщение Anonymous
-