两个不同服务器之间的数据库关系

import psycopg2
from psycopg2 import sql

def sync_data(source_conn_str, dest_conn_str):
    try:
        # 连接源数据库
        source_conn = psycopg2.connect(source_conn_str)
        source_cursor = source_conn.cursor()

        # 连接目标数据库
        dest_conn = psycopg2.connect(dest_conn_str)
        dest_cursor = dest_conn.cursor()

        # 查询源数据库中的数据
        source_cursor.execute("SELECT id, name FROM users")
        records = source_cursor.fetchall()

        # 插入数据到目标数据库
        for record in records:
            dest_cursor.execute(
                sql.SQL("INSERT INTO users (id, name) VALUES ({}, {})").format(
                    sql.Literal(record[0]), sql.Literal(record[1])
                )
            )

        # 提交事务
        dest_conn.commit()

    except Exception as e:
        print(f"Error: {e}")
        dest_conn.rollback()

    finally:
        source_cursor.close()
        source_conn.close()
        dest_cursor.close()
        dest_conn.close()

# 示例调用
source_conn_str = "dbname=source_db user=user password=password host=source_host port=5432"
dest_conn_str = "dbname=dest_db user=user password=password host=dest_host port=5432"
sync_data(source_conn_str, dest_conn_str)