SQLAlchemy双会话配置下如何解决对象已绑定其他会话报错并同步数据

你碰到的两个问题的根因如下：

1. 报错sqlalchemy.exc.InvalidRequestError: Object is already attached to session的原因：SQLAlchemy的ORM实例同一时间只能关联一个会话，你从read会话查询出来的实例默认绑定在read会话上，直接往write会话add就会触发该异常。
2. read会话对象ID为空的原因：两个会话是完全隔离的，write会话提交后生成的主键、字段变更等不会自动同步到read会话里缓存的旧实例上。

首先导入SQLAlchemy的实例检查工具：

from sqlalchemy import inspect

第一步：安全将对象添加到write会话 #

根据你的需求实现判断逻辑，两种可选实现方式：

• 方式1：显式判断会话后操作

  obj_session = inspect(obj).session
  # 对象已经绑定到write会话直接add
  if obj_session is db.write:
      db.write.add(obj)
  else:
      # 对象绑定了其他会话先移除再添加
      if obj_session is not None:
          obj_session.expunge(obj)
      db.write.add(obj)
  # 提交写操作
  db.write.commit()
  

• 方式2：用merge方法自动处理跨会话实例，代码更简洁

  # merge会自动处理跨会话绑定，返回绑定到write会话的最新实例
  obj = db.write.merge(obj)
  db.write.commit()
  

第二步：同步read会话的对象数据 #

两种同步方案根据业务场景选择即可：

• 方案1：主动同步最新实例到read会话，适合需要保留read会话其他缓存的场景

  # 刷新write会话的实例获取最新状态
  db.write.refresh(obj)
  # 移除read会话中缓存的旧实例
  old_obj = db.read.get(type(obj), obj.id)
  if old_obj:
      db.read.expunge(old_obj)
  # 把最新实例合并到read会话
  db.read.merge(obj)
  

• 方案2：清空read会话缓存，适合对读一致性要求高的场景

  db.write.commit()
  # 让read会话所有缓存实例过期，下次查询自动拉取最新数据
  db.read.expire_all()
  

补充优化建议 #

• 尽量不要跨会话传递ORM实例，优先传递主键，需要操作时从对应会话查询实例，能从根源避免跨会话绑定的问题
• 如果你的底层是一主多从架构，要注意主从同步延迟，写入后立刻读的场景可以临时走write会话，避免读到旧数据

内容的提问来源于stack exchange，提问作者Cyril N.