SQLAlchemy AsyncEngine执行操作触发ObjectNotExecutableError问题求助

SQLAlchemy 1.4及以上版本的异步执行接口await conn.execute()不再直接接收原生字符串作为执行参数，要求必须传入SQLAlchemy封装的可执行对象（比如text()包裹的SQL语句、ORM查询对象等）。你遇到的两类报错本质是同一个问题：

• 直接执行原生SQL的场景，你传入了未封装的字符串格式SELECT语句，触发参数校验失败
• PostGIS索引创建场景，旧版本GeoAlchemy2生成GIST索引时会直接输出原生SQL字符串，未封装为可执行对象，异步引擎执行时触发报错
  另外你使用的Python 3.6已经停止官方维护，SQLAlchemy 1.4对Python 3.6的兼容性存在已知缺陷，也可能放大这类适配问题。

原生SQL执行场景修复 #

引入sqlalchemy.text包裹原生SQL字符串后再传入执行，修改后代码示例：

from sqlalchemy import text

async with self.async_engine.connect() as con:
    query = "SELECT id, name FROM item LIMIT 50;"
    result = await con.execute(text(query))

PostGIS索引创建场景修复 #

可从以下两个方案中任选其一：

• 方案一：表结构创建、索引创建等DDL操作改用同步引擎执行，异步引擎仅用于常规业务数据读写，规避DDL执行过程中内部生成原生SQL的场景
• 方案二：升级依赖版本，首先将Python版本升级到3.7及以上，再将SQLAlchemy升级到1.4.30以上、GeoAlchemy2升级到0.10.0以上，上述版本已经修复了异步引擎下PostGIS索引创建的自动封装问题

• 所有传入异步execute方法的语句都必须经过text()封装，或使用SQLAlchemy Core/ORM的查询表达式生成，禁止直接传入原生字符串
• 建议尽快升级Python版本到3.8及以上，避免低版本Python带来的各类依赖兼容性风险

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