如何利用SQLAlchemy将数据库查询追踪至源码，排查事务问题？

首先修正你用来查找长事务的SQL语句（原语句存在语法错误，and应改为where）：

select query_start, application_name, state, query, * 
from pg_stat_activity 
where state != 'idle' 
order by query_start;

针对剩余难以定位源码出处的"idle in transactions"查询，以下是几个更简便的排查方法：

• 增强pg_stat_activity查询维度
  补充查询pid、xact_start（事务启动时间）、client_addr、client_port等字段，能帮你定位到具体的客户端来源和事务持续时长，方便缩小排查范围：

  select 
    pid,
    xact_start,
    query_start,
    client_addr,
    client_port,
    application_name,
    state,
    query
  from pg_stat_activity 
  where state = 'idle in transaction' 
  order by xact_start;
  

• 利用PostgreSQL日志定位事务链路
  临时调整数据库日志参数，记录事务相关细节：

  • 设置log_transaction_timestamp = on：记录每个事务的时间戳
  • 设置log_statement = 'mod'：记录所有数据修改语句（如果需要更详细可设为all）
  • 设置log_connections = on：记录客户端连接信息
    重载配置后，通过日志可以追踪到事务的完整执行链路，包括启动语句、客户端信息，从而对应到源码位置。

• 关联pg_locks分析锁持有情况
  空闲事务往往持有锁，通过关联pg_locks可以看到这些事务锁定的对象，结合业务逻辑反推源码出处：

  select 
    a.pid,
    a.xact_start,
    a.application_name,
    a.query,
    l.locktype,
    l.relation::regclass as locked_table
  from pg_stat_activity a
  join pg_locks l on a.pid = l.pid
  where a.state = 'idle in transaction'
  order by a.xact_start;
  

• 增大查询语句记录长度
  默认track_activity_query_size可能不足以记录完整的长查询，临时修改该参数（无需重启）：

  set track_activity_query_size = 8192;
  

  之后查询pg_stat_activity就能看到完整的SQL语句，帮助你匹配到源码中的对应逻辑。

• 应用层连接池与事务检查
  排查应用侧的连接池配置，确认是否存在未正确回收的连接；同时检查ORM框架或业务代码中的事务管理逻辑，比如是否有代码路径遗漏了事务提交/回滚操作，尤其是异常分支中的事务处理。

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