数据库同步如何搭建

import mysql.connector
from datetime import datetime, timedelta

def sync_databases(source_config, target_config):
    # 连接到源数据库
    source_conn = mysql.connector.connect(**source_config)
    source_cursor = source_conn.cursor()

    # 连接到目标数据库
    target_conn = mysql.connector.connect(**target_config)
    target_cursor = target_conn.cursor()

    try:
        # 获取上次同步时间
        last_sync_time = get_last_sync_time(target_conn)

        # 查询自上次同步以来更改的数据
        query = f"SELECT * FROM your_table WHERE updated_at > '{last_sync_time}'"
        source_cursor.execute(query)
        rows = source_cursor.fetchall()

        # 将更改的数据插入目标数据库
        for row in rows:
            insert_query = "INSERT INTO your_table VALUES (%s, %s, %s, %s)"
            target_cursor.execute(insert_query, row)

        # 更新上次同步时间
        update_sync_time(target_conn, datetime.now())

        # 提交事务
        target_conn.commit()
    except Exception as e:
        print(f"Error during sync: {e}")
    finally:
        source_cursor.close()
        source_conn.close()
        target_cursor.close()
        target_conn.close()

def get_last_sync_time(conn):
    cursor = conn.cursor()
    cursor.execute("SELECT last_sync FROM sync_metadata")
    result = cursor.fetchone()
    return result[0] if result else datetime.min

def update_sync_time(conn, new_time):
    cursor = conn.cursor()
    cursor.execute("UPDATE sync_metadata SET last_sync = %s", (new_time,))
    conn.commit()

# 配置数据库连接信息
source_config = {
    'host': 'source_host',
    'user': 'source_user',
    'password': 'source_password',
    'database': 'source_db'
}

target_config = {
    'host': 'target_host',
    'user': 'target_user',
    'password': 'target_password',
    'database': 'target_db'
}

# 执行同步
sync_databases(source_config, target_config)