mysql从库上做增量备份

import mysql.connector
from mysql.connector import Error
import subprocess

def take_incremental_backup():
    try:
        # 连接到MySQL数据库
        connection = mysql.connector.connect(host='localhost',
                                             database='your_database',
                                             user='your_username',
                                             password='your_password')
        if connection.is_connected():
            cursor = connection.cursor()
            
            # 获取当前二进制日志文件名和位置
            cursor.execute("SHOW MASTER STATUS")
            result = cursor.fetchone()
            binlog_file, binlog_position = result[0], result[1]
            
            # 执行增量备份命令（使用mysqldump工具）
            backup_command = f"mysqldump --single-transaction --flush-logs --master-data=2 --skip-lock-tables -u your_username -p your_password your_database > incremental_backup.sql"
            subprocess.run(backup_command, shell=True)
            
            # 记录二进制日志文件名和位置，以便下次增量备份
            with open('backup_info.txt', 'w') as f:
                f.write(f"{binlog_file} {binlog_position}")
                
    except Error as e:
        print("Error while connecting to MySQL", e)
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()

# 调用函数执行增量备份
take_incremental_backup()