python mysql数据库监听

您可以使用Python中的MySQL Replication库来监听MySQL数据库。该库提供了一个ReplicationConnection类，该类在MySQL服务器上创建一个基于binlog的连接，并提供了一些有用的方法来处理binlog事件。以下是一个示例代码：

from mysql_replication import BinLogStreamReader

config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "passwd": "password"
}

stream = BinLogStreamReader(
    connection_settings=config,
    server_id=100,
    blocking=True,
    only_events=['tablemap', 'writerows', 'updaterows', 'deleterows']
)

for binlogevent in stream:
    if binlogevent.event_type == "tablemap":
        table_name = binlogevent.table
        print("Table Name: ", table_name)
    elif binlogevent.event_type == "writerows":
        for row in binlogevent.rows:
            print("Insert Row: ", row)
    elif binlogevent.event_type == "updaterows":
        for row in binlogevent.rows:
            print("Update Row: ", row)
    elif binlogevent.event_type == "deleterows":
        for row in binlogevent.rows:
            print("Delete Row: ", row)

stream.close()

此代码连接到本地MySQL服务器的root用户，使用密码password，并监听所有表的插入，更新和删除事件。您可以更改配置以适应您的环境，并使用适当的only_events参数来监听特定的事件类型。