SQLAlchemy中create_async_engine的connect_args配置问题

你用同步引擎时通过connect_args的options参数指定schema的方法，不适用于基于asyncpg的异步引擎——因为asyncpg的connect()方法不接受options参数，对应的配置项是server_settings。下面是两种可行的替代方案：

方案1：通过connect_args传递server_settings #

直接在connect_args中使用server_settings字典来设置search_path：

async_engine = create_async_engine(
    ASYNC_URL,
    connect_args={'server_settings': {'search_path': dbschema}},
    echo=False
)

方案2：将search_path嵌入数据库URL #

把schema配置直接附加到异步数据库URL的查询参数中，注意需要对特殊字符进行URL编码（=要转成%3D）：

# 假设dbschema是"my_schema"
ASYNC_URL = "postgresql+asyncpg://user:password@host:port/dbname?options=-csearch_path%3Dmy_schema"
async_engine = create_async_engine(ASYNC_URL, echo=False)

验证配置是否生效 #

可以连接后执行查询确认当前的search_path：

from sqlalchemy import text

async def check_search_path():
    async with async_engine.connect() as conn:
        result = await conn.execute(text("SHOW search_path"))
        print("当前search_path:", result.scalar())

# 运行验证
import asyncio
asyncio.run(check_search_path())

内容的提问来源于stack exchange，提问作者LivelyECDSA