如何克隆已传入的psycopg2连接用于工作线程？

我之前也碰到过一模一样的场景——外部传入的连接没法直接给多线程用，必须搞个独立复本才行。其实psycopg2的连接对象本身就提供了获取配置参数的方法，完全可以用它复刻出一个配置一致的全新连接，而且和原连接彻底独立，不会出现共享连接导致的查询序列化问题。

基础复刻方法：复用连接核心参数 #

最直接的方式是用原连接的get_dsn_parameters()方法提取所有连接配置，再用这些参数创建新连接：

import psycopg2

def duplicate_connection(original_conn):
    # 提取原连接的所有核心参数（dbname、user、password、host、port等）
    conn_params = original_conn.get_dsn_parameters()
    # 用这些参数创建完全独立的新连接
    new_conn = psycopg2.connect(**conn_params)
    return new_conn

这个方法会生成一个和原连接配置完全一致的新连接，两者相互独立，工作线程用新连接执行查询时，完全不会影响原连接的运行状态。

进阶：继承会话级自定义配置 #

如果原连接有一些会话级的自定义设置（比如search_path、时区、客户端编码这类），你可以把这些配置也同步到新连接里，比如复制search_path的示例：

def duplicate_connection_with_session_settings(original_conn):
    # 先复刻基础连接配置
    conn_params = original_conn.get_dsn_parameters()
    new_conn = psycopg2.connect(**conn_params)
    
    # 复制原连接的search_path设置
    with original_conn.cursor() as cur:
        cur.execute("SHOW search_path;")
        original_search_path = cur.fetchone()[0]
    
    with new_conn.cursor() as cur:
        cur.execute(f"SET search_path TO {original_search_path};")
        new_conn.commit()
    
    # 其他需要同步的会话变量（比如时区、客户端编码）都可以用类似方式处理
    return new_conn

关键提醒 #

psycopg2的连接对象本身不是线程安全的，绝对不能在多线程之间共享同一个连接，每个工作线程必须持有自己的独立连接，上面的方法正好完美解决这个问题。而且get_dsn_parameters()会自动返回所有必要的连接参数，不需要手动逐个提取属性，既高效又不容易出错。

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