mysql实时同步软件

from pymysqlreplication import BinLogStreamReader
from pymysqlreplication.row_event import (
    DeleteRowsEvent,
    UpdateRowsEvent,
    WriteRowsEvent,
)

config = {
    "host": "source_host",
    "port": 3306,
    "user": "replication_user",
    "password": "password",
    "server_id": 100,
    "blocking": True,
    "resume_stream": True
}

stream = BinLogStreamReader(
    connection_settings=config,
    server_id=100,
    only_events=[DeleteRowsEvent, UpdateRowsEvent, WriteRowsEvent],
    only_tables=['table1', 'table2']
)

for event in stream:
    if isinstance(event, WriteRowsEvent):
        for row in event.rows:
            print(f"Insert: {row['values']}")
    elif isinstance(event, UpdateRowsEvent):
        for row in event.rows:
            print(f"Update: {row['before_values']} -> {row['after_values']}")
    elif isinstance(event, DeleteRowsEvent):
        for row in event.rows:
            print(f"Delete: {row['values']}")

stream.close()