mysql 实时同步

MySQL实时同步是指将一个MySQL数据库的更改实时同步到另一个MySQL数据库，以保持数据的一致性。实时同步可以用于多个场景，例如数据备份、数据迁移、数据分发等。

实现MySQL实时同步的方法有多种，其中一种常用的方法是使用MySQL的binlog日志。binlog是MySQL的二进制日志，记录了数据库的所有更改操作，包括插入、更新、删除等。通过解析binlog日志，可以获取到数据库的更改操作，并将其应用到另一个MySQL数据库中，从而实现实时同步。

下面是一个示例代码，演示了如何使用binlog实现MySQL实时同步：

import pymysql
import time
import threading
def sync_data():
    # 连接源数据库
    source_conn = pymysql.connect(host='source_host', user='source_user', password='source_password', database='source_database')
    source_cursor = source_conn.cursor()
    # 连接目标数据库
    target_conn = pymysql.connect(host='target_host', user='target_user', password='target_password', database='target_database')
    target_cursor = target_conn.cursor()
    # 获取源数据库的binlog文件名和位置
    source_cursor.execute("SHOW MASTER STATUS")
    binlog_file, binlog_position = source_cursor.fetchone()
    # 开始实时同步
    while True:
        # 读取binlog日志
        source_cursor.execute(f"SHOW BINLOG EVENTS IN '{binlog_file}' FROM {binlog_position}")
        events = source_cursor.fetchall()
        # 解析binlog日志并应用到目标数据库
        for event in events:
            # 获取事件类型和数据
            event_type = event[5]
            event_data = event[9]
            # 根据事件类型进行相应操作
            if event_type == "Write_rows_event":
                # 插入操作
                target_cursor.execute(event_data)
            elif event_type == "Update_rows_event":
                # 更新操作
                target_cursor.execute(event_data)
            elif event_type == "Delete_rows_event":
                # 删除操作
                target_cursor.execute(event_data)
        # 更新目标数据库的binlog位置
        target_cursor.execute(f"SET GLOBAL gtid_slave_pos = '{binlog_file}:{binlog_position}'")
        # 提交事务
        target_conn.commit()
        # 休眠一段时间，继续下一次同步
        time.sleep(1)
# 启动实时同步线程
sync_thread = threading.Thread(target=sync_data)
sync_thread.start()

在上述示例代码中，首先通过pymysql库连接源数据库和目标数据库。然后使用`SHOW MASTER STATUS`命令获取源数据库的binlog文件名和位置。接下来进入一个无限循环，每次循环中读取binlog日志并解析，然后根据事件类型进行相应的操作，将操作应用到目标数据库中。最后更新目标数据库的binlog位置，并提交事务。循环过程中使用`time.sleep(1)`进行休眠，以便控制同步的频率。

需要注意的是，上述示例代码只是一个简单的示例，实际使用中还需要考虑更多的情况，例如异常处理、性能优化等。MySQL还提供了其他实现实时同步的方法，例如使用主从复制、使用第三方工具等。根据具体的需求和场景，可以选择合适的方法来实现MySQL实时同步。