故障转移时因序列问题导致PostgreSQL逻辑复制失败

问题核心 #

主备切换后，新发布端B的序列last_value与原发布端A完全一致，但A作为订阅端无法正常复制B的插入数据，本质原因是序列的状态未完全同步——你的脚本仅同步了last_value，忽略了PostgreSQL序列的is_called属性。

原因分析 #

PostgreSQL序列的行为由两个参数共同决定：

• last_value：序列的当前最大值
• is_called：标记是否已调用过nextval（true时下一次nextval返回last_value+1，false时返回last_value）

你的脚本通过表的MAX(主键列)来设置序列值，这种方式存在两个关键问题：

1. 序列的last_value可能大于表中主键的最大值（比如存在调用了nextval但未插入数据的场景）
2. 未同步is_called状态，导致两端序列的nextval生成逻辑不一致

举个典型场景：

• 原发布端A的序列状态：last_value=100, is_called=false，下一次nextval返回100
• 脚本用MAX(id)=100设置B的序列，执行setval('orders_id_seq',100)，B的序列状态变为last_value=100, is_called=true，下一次nextval返回101
• 当B插入ID=101的数据同步到A时，若A后续有本地写入，会生成ID=100（符合自身序列逻辑），但如果切换前A存在未提交的事务提交了ID=100，后续A本地写入会生成101，与B同步过来的ID冲突，直接导致复制失败。

修正后的同步脚本 #

直接读取源端序列的完整状态（last_value+is_called），在目标端还原完全一致的序列状态，避免依赖表的主键最大值：

import psycopg2

def sync_sequence(table, source_conn, target_conn):
    with source_conn.cursor() as source_cursor:
        # 查询表关联的序列信息（采用参数化查询避免SQL注入）
        source_cursor.execute("""
            SELECT column_name, column_default 
            FROM information_schema.columns 
            WHERE table_name = %s AND column_default LIKE 'nextval%%'
        """, (table,))
        sequence_data = source_cursor.fetchone()
        
        if not sequence_data:
            print(f"表{table}未关联序列，跳过同步")
            return
        
        sequence_column, sequence_default = sequence_data
        # 解析序列名称（兼容带schema的序列格式）
        sequence_name = sequence_default.split("'")[1]
        
        # 获取源端序列的完整状态
        source_cursor.execute(f"SELECT last_value, is_called FROM {sequence_name}")
        seq_last_val, seq_is_called = source_cursor.fetchone()
        
        # 在目标端设置序列的完整状态
        with target_conn.cursor() as target_cursor:
            # setval第三个参数指定is_called状态，保证序列行为完全一致
            target_cursor.execute("""
                SELECT setval(%s, %s, %s);
            """, (sequence_name, seq_last_val, seq_is_called))
            target_conn.commit()
            print(f"序列{sequence_name}同步完成：last_value={seq_last_val}, is_called={seq_is_called}")

验证步骤 #

切换前后，分别在A、B两端执行以下命令，确认序列状态完全一致：

SELECT last_value, is_called FROM orders_id_seq;

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