sqlalchemy和asyncpg＆＃x2013;设置postgres statement_timeout

Question

做的时候

engine: AsyncEngine = create_async_engine(...)

在这样

async with engine.connect() as conn:
    result: Result = await conn.execute(text("""..."""))

，我想指定超时。理想情况下，我能够设置仅用于此查询执行。我对Sqlalchemy进行超时并取消查询执行我也很好，但是我找不到设置的方法。

Answer 1

create_async_engine(
            db_url, connect_args={"command_timeout": 28.0}
        )

在几秒钟内使用command_timeout in connect_args

Answer 2

command_timeout仅在应用程序级别上设置。这意味着在应用程序中的超时错误之后，查询仍将在数据库中运行。要在数据库级别设置超时，您应该使用server_settings：

create_async_engine(
    db_url, connect_args={"server_settings": {"statement_timeout": "10000"}},
)