mysql监控数据变化

import pymysqlreplication

def main():
    stream = pymysqlreplication.BinLogStreamReader(
        connection_settings={
            "host": "localhost",
            "port": 3306,
            "user": "root",
            "passwd": "password"
        },
        server_id=100,
        blocking=True,
        only_events=[pymysqlreplication.events.WriteRowsEvent, pymysqlreplication.events.UpdateRowsEvent, pymysqlreplication.events.DeleteRowsEvent]
    )

    for event in stream:
        if isinstance(event, pymysqlreplication.events.WriteRowsEvent):
            print("Insert rows:", event.rows)
        elif isinstance(event, pymysqlreplication.events.UpdateRowsEvent):
            print("Update rows:", event.rows)
        elif isinstance(event, pymysqlreplication.events.DeleteRowsEvent):
            print("Delete rows:", event.rows)

    stream.close()

if __name__ == "__main__":
    main()