mysql主从延迟监控脚本

import subprocess
import time

def get_slave_delay():
    try:
        # 执行MySQL命令获取从服务器状态
        result = subprocess.run(['mysql', '-u', 'username', '-ppassword', '-e', 'SHOW SLAVE STATUS\G'], capture_output=True, text=True)
        if result.returncode != 0:
            raise Exception("Failed to execute MySQL command")
        
        # 解析输出结果，获取Seconds_Behind_Master值
        for line in result.stdout.split('\n'):
            if 'Seconds_Behind_Master' in line:
                delay = line.split(':')[1].strip()
                return int(delay) if delay.isdigit() else None
        
        raise Exception("Seconds_Behind_Master not found in MySQL output")
    
    except Exception as e:
        print(f"Error: {e}")
        return None

def monitor_slave_delay(threshold):
    while True:
        delay = get_slave_delay()
        if delay is not None:
            print(f"Current slave delay: {delay} seconds")
            if delay > threshold:
                print(f"ALERT: Slave delay exceeds threshold ({threshold} seconds)!")
                # 在这里可以添加发送警报的代码，如发送邮件或短信
        else:
            print("Unable to determine slave delay")
        
        time.sleep(10)  # 每10秒检查一次延迟

# 设置延迟阈值（秒）
threshold = 60
monitor_slave_delay(threshold)