mysql 增量索引同步

import pymysql
from pymysqlreplication import BinLogStreamReader

def sync_index():
    config = {
        "host": "localhost",
        "port": 3306,
        "user": "root",
        "passwd": "password"
    }

    stream = BinLogStreamReader(
        connection_settings=config,
        server_id=100,
        only_events=[],
        only_tables=['your_table'],
        freeze_schema=True
    )

    for event in stream:
        if isinstance(event, pymysqlreplication.events.WriteRowsEvent):
            for row in event.rows:
                # 处理新增数据
                print(f"Insert: {row['values']}")
                # 更新索引
                update_index(row['values'])
        elif isinstance(event, pymysqlreplication.events.UpdateRowsEvent):
            for row in event.rows:
                # 处理修改数据
                print(f"Update: {row['after_values']}")
                # 更新索引
                update_index(row['after_values'])

    stream.close()

def update_index(data):
    # 更新索引的逻辑
    pass

if __name__ == "__main__":
    sync_index()