python 增量备份mysql

import mysql.connector
from mysql.connector import Error
import datetime
import os

def backup_database(host_name, user_name, user_password, db_name):
    try:
        connection = mysql.connector.connect(host=host_name,
                                             database=db_name,
                                             user=user_name,
                                             password=user_password)

        if connection.is_connected():
            cursor = connection.cursor()
            # 获取当前时间戳
            timestamp = datetime.datetime.now().strftime('%Y%m%d%H%M%S')
            backup_file = f"{db_name}_incremental_backup_{timestamp}.sql"

            # 使用mysqlbinlog工具进行增量备份
            os.system(f"mysqlbinlog --read-from-remote-server --host={host_name} --user={user_name} --password={user_password} {db_name} > {backup_file}")

            print(f"Incremental backup completed successfully: {backup_file}")

    except Error as e:
        print(f"Error while connecting to MySQL: {e}")
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

# 示例调用
backup_database('localhost', 'root', 'password', 'mydatabase')