#!/usr/bin/env python
#-*- encoding: utf8 -*-
import mysql.connector
import get_mysql_conn_info
"""
SHOW SLAVE STATUS命令输出内容
"""
class GetSlaveResult:
"""
getdbconfig 参数是一个列表，第一列是IP，第二列是账号，第三列是密码，第四列是端口号。
"""
def __init__(self,getdbconfig):
self.getdbconfig = getdbconfig
"""
获取 SHOW SLAVE STATUS 输出结果
"""
def get_slave_status(self):
dbconfig = self.getdbconfig
for i in range(int(len(dbconfig))):
show_slave_status = "SHOW slave STATUS;"
cnn = mysql.connector.connect(host=dbconfig[i][0] ,user=dbconfig[i][1] ,password=dbconfig[i][2] ,port=dbconfig[i][3])
cursor = cnn.cursor(dictionary=True)
cursor.execute(show_slave_status)
result_fet = cursor.fetchall()
result = result_fet[0]
result["checkmysql_host"] = dbconfig[i][0]
result["checkmysql_user"] = dbconfig[i][1]
result["checkmysql_port"] = int(dbconfig[i][3])
return result
"""
检查SHOW SLAVE STATUS状态
"""
def check_slave_status(self):
check_ture_false_slave_status = True
result = self.get_slave_status()
if result.get('Slave_IO_Running') == 'Yes' and result.get('Slave_SQL_Running') == 'Yes':
pass
else:
check_ture_false_slave_status = False
print "主机名: %s , 端口号: %s , Slave_IO_Running 状态 = %s , Slave_SQL_Running 状态 = %s " %(str(result.get('checkmysql_host')),str(result.get('checkmysql_port')),str(result.get('Slave_IO_Running')),str(result.get('Slave_SQL_Running')))
"""
获取Last_SQL_Error内容
"""
def get_last_sql_error(self):
check_ture_false_last_sql_error = True
result = self.get_slave_status()
if result.get('Last_SQL_Error')== '':
pass
else:
check_ture_false_last_sql_error = False
print "主机名: %s , 端口号: %s , Last_SQL_Error 内容 = %s " %(str(result.get('checkmysql_host')),str(result.get('checkmysql_port')),str(result.get('Last_SQL_Error')))
checkdbconfig = get_mysql_conn_info.GetConn('/data/lgj/dblist.xlsx').get_csv()
print_result = GetSlaveResult(checkdbconfig)
print_result.check_slave_status()
print_result.get_last_sql_error()