数据同步源代码

以下是一份使用Python语言编写的数据同步源代码，可以将一个数据库中的数据同步到另一个数据库中：

import psycopg2

# 源数据库连接参数
src_host = "localhost"
src_port = "5432"
src_dbname = "source_db"
src_user = "source_user"
src_password = "source_password"

# 目标数据库连接参数
dest_host = "localhost"
dest_port = "5432"
dest_dbname = "dest_db"
dest_user = "dest_user"
dest_password = "dest_password"

# 连接源数据库和目标数据库
src_conn = psycopg2.connect(
    host=src_host,
    port=src_port,
    dbname=src_dbname,
    user=src_user,
    password=src_password
)
dest_conn = psycopg2.connect(
    host=dest_host,
    port=dest_port,
    dbname=dest_dbname,
    user=dest_user,
    password=dest_password
)

# 从源数据库查询数据
src_cursor = src_conn.cursor()
src_cursor.execute("SELECT * FROM table_name")
rows = src_cursor.fetchall()

# 将数据插入到目标数据库
dest_cursor = dest_conn.cursor()
for row in rows:
    dest_cursor.execute("INSERT INTO table_name VALUES (%s, %s, %s)", row)
dest_conn.commit()

# 关闭数据库连接
src_cursor.close()
src_conn.close()
dest_cursor.close()
dest_conn.close()

该源代码首先定义了源数据库和目标数据库的连接参数，然后使用psycopg2库连接到源数据库和目标数据库。接着，从源数据库查询数据，并将数据插入到目标数据库中。最后，关闭数据库连接。

需要注意的是，该源代码只是一个简单的数据同步示例，实际应用中需要根据具体情况进行修改和优化。例如，可以添加数据过滤和数据转换等操作，以确保数据同步的准确性和完整性。同时，还需要考虑数据同步的效率和安全性等问题。