用python代码写一个用mysql-replication监控MySQL表变动的功能，表的名字为task_name

好的，以下是一个使用 mysql-replication 包监控 MySQL 表变动的 Python 代码示例：

from mysql_replication import BinLogStreamReader
from mysql.connector import connect

# 连接 MySQL 数据库
conn = connect(host='localhost', user='root', password='password', database='test')

# 创建 BinLogStreamReader 对象
stream = BinLogStreamReader(
    connection_settings={
        "host": "localhost",
        "port": 3306,
        "user": "root",
        "password": "password"
    },
    server_id=100,
    blocking=True,
    only_events=["tablemap", "writerows", "updaterows", "deleterows"],
    only_schemas=["test"],
    only_tables=["task_name"]
)

# 监听 MySQL 表变动
for binlogevent in stream:
    for row in binlogevent.rows:
        event = {"schema": binlogevent.schema, "table": binlogevent.table}
        if binlogevent.event_type == "tablemap":
            event["column_schemas"] = binlogevent.column_schemas
        elif binlogevent.event_type == "writerows":
            event["action"] = "insert"
            event["rows"] = row["values"]
        elif binlogevent.event_type == "updaterows":
            event["action"] = "update"
            event["rows"] = row["after_values"]
            event["old_rows"] = row["before_values"]
        elif binlogevent.event_type == "deleterows":
            event["action"] = "delete"
            event["rows"] = row["values"]
        # 打印表变动信息
        print(event)

# 关闭 BinLogStreamReader 对象
stream.close()

# 关闭数据库连接
conn.close()

在上述代码中，我们首先使用 mysql.connector 包连接到 MySQL 数据库。然后，我们创建一个 BinLogStreamReader 对象，该对象可以监听 MySQL 数据库的二进制日志（binlog），并实时获取表变动信息。在创建 BinLogStreamReader 对象时，我们指定了需要监听的表名为 task_name，只监听 tablemap、writerows、updaterows 和 deleterows 事件，只监听 test 数据库。接着，我们使用 for 循环遍历 BinLogStreamReader 对象，处理每个表变动事件，并打印表变动信息。最后，我们在循环结束后关闭 BinLogStreamReader 对象和数据库连接。

需要注意的是，上述代码仅演示了如何使用 mysql-replication 包监控 MySQL 表变动，实际使用时还需要根据自己的需求进行修改。例如，我们可以将表变动信息保存到文件、发送邮件或调用其他 API 进行处理。