SQLAlchemy插入PostgreSQL数据时报TypeError: NoneType对象不可调用

问题现象 #

使用SQLAlchemy向PostgreSQL的products表执行插入操作时，抛出如下错误：

TypeError: 'NoneType' object is not callable

原问题实现代码：

from sqlalchemy import create_engine, text
from db.db import engine

def register_new_item(item_name, item_age, item_dress):
    with engine.connect() as conn:
        trans = conn.begin()
        conn.execute(text("""
            INSERT INTO products(
                item_name,
                item_age,
                item_dress
            ) VALUES (
                :item_name,
                :item_age,
                :item_dress
            )               
        """),
            item_name= item_name,
            item_age= item_age,
            item_dress= item_dress
        )
        trans.commit()
        conn.close()

根因分析 #

报错由两个不规范写法共同触发：

1. 参数传递格式不符合版本要求：SQLAlchemy 1.4及以上（含2.0正式版）中，conn.execute()不支持直接将SQL绑定参数作为关键字参数散传，绑定参数必须封装为字典作为第二个位置参数传入。原代码直接传item_name=xxx的写法，会被框架识别为执行配置项，内部处理时会尝试调用对应配置的处理钩子，找不到钩子时拿到None值尝试调用，就会抛出NoneType不可调用的错误。
2. 事务和连接管理逻辑冲突：原代码同时使用with engine.connect()上下文管理器、手动创建事务、手动调用conn.close()，多层生命周期管理逻辑冲突，会在部分版本中导致连接状态异常，放大报错概率。

修复方案 #

两种标准写法选其一即可。

写法1：自动托管事务（推荐） #

使用engine.begin()上下文自动管理事务生命周期：块内代码无异常则自动提交，出现异常自动回滚，退出块自动关闭连接，不需要手动写commit、close逻辑。

from sqlalchemy import text
from db.db import engine

def register_new_item(item_name, item_age, item_dress):
    with engine.begin() as conn:
        conn.execute(
            text("""
                INSERT INTO products(
                    item_name,
                    item_age,
                    item_dress
                ) VALUES (
                    :item_name,
                    :item_age,
                    :item_dress
                )               
            """),
            # 绑定参数封装为字典传入
            {
                "item_name": item_name,
                "item_age": item_age,
                "item_dress": item_dress
            }
        )

写法2：手动控制事务 #

如果需要自定义事务流程，按规范手动实现，禁止在with块内手动调用conn.close()：

from sqlalchemy import text
from db.db import engine

def register_new_item(item_name, item_age, item_dress):
    with engine.connect() as conn:
        trans = conn.begin()
        try:
            conn.execute(
                text("""
                    INSERT INTO products(
                        item_name,
                        item_age,
                        item_dress
                    ) VALUES (
                        :item_name,
                        :item_age,
                        :item_dress
                    )               
                """),
                # 绑定参数封装为字典传入
                {
                    "item_name": item_name,
                    "item_age": item_age,
                    "item_dress": item_dress
                }
            )
            trans.commit()
        except Exception:
            trans.rollback()
            raise

补充排查点 #

如果调整写法后仍报错，检查两项配置：

• 确认db.db模块中engine对象正确初始化，create_engine()的返回值正确赋值给engine变量，不存在导入时engine为None的情况
• 确认环境中安装了对应版本的PostgreSQL驱动，比如psycopg2-binary或psycopg[binary]，驱动和engine创建时指定的连接协议匹配

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