python脚本 监控MySQL slave 状态
生活随笔
收集整理的這篇文章主要介紹了
python脚本 监控MySQL slave 状态
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
#!/usr/bin/python
# !gbk
import os
import sys
mysqlbase = '/usr/bin/mysql'
host = 'ip'
user = 'root'
passw = 'xxxxxx'
def insert_info(item): # 判斷當主從不同步時用函數把狀態信息寫入系統文件
patt = r'/tmp'
filename = 'slave_jk.txt'
writ = ' '
f = open(patt + '/' + filename, 'a')
writ = writ + time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
writ = writ + item
f.write(writ)
f.close()
# 把當前從庫同步狀態信息取出來放列表中
info = os.popen(mysqlbase + ' -h %s -u%s -p%s -e "show slave status\G"|grep -E "Slave_IO_Running|Slave_SQL_Running|Seconds_Behind_Master|Master_Log_File|Read_Master_Log_Pos|Relay_Master_Log_File|Exec_Master_Log_Pos"' % (host, user, passw)).read()
info_list = info.split()
info_tup = {}
js = 0
_idx = 0
pd = len(info_list) / 2
for idx, item in enumerate(info_list):
js += 1
if js > pd:
continue
info_tup[info_list[_idx]] = info_list[_idx + 1]
_idx += 2
if len(sys.argv) == 1: # 當運行腳本不加參數時給出提示執行腳本格式
print('your can insert python + pyname + Seconds_Behind_Master or file_pos or io_sql')
elif sys.argv[1] == 'Seconds_Behind_Master':
if info_tup['Seconds_Behind_Master:'] == '0':
print(0)
else:
item = 'Seconds_Behind_Master ' + info_tup['Seconds_Behind_Master:']
insert_info(item)
elif sys.argv[1] == 'file_pos':
if info_tup['Master_Log_File:'] == info_tup['Relay_Master_Log_File:'] and info_tup['Read_Master_Log_Pos:'] == info_tup['Exec_Master_Log_Pos:']:
print(0)
else:
item = 'Master_Log_File ' + info_tup['Master_Log_File:'] + ' Relay_Master_Log_File ' + info_tup['Relay_Master_Log_File:'] + ' Read_Master_Log_Pos ' + info_tup['Read_Master_Log_Pos:'] + ' Exec_Master_Log_Pos ' + info_tup['Exec_Master_Log_Pos:']
insert_info(item)
elif sys.argv[1] == 'io_sql':
if info_tup['Slave_IO_Running:'] == 'Yes' or info_tup['Slave_SQL_Running:'] == 'Yes':
print(0)
else:
item = 'Slave_IO_Running ' + info_tup['Slave_IO_Running:'] + ' Slave_SQL_Running ' + info_tup['Slave_SQL_Running:']
insert_info(item)
# !gbk
import os
import sys
mysqlbase = '/usr/bin/mysql'
host = 'ip'
user = 'root'
passw = 'xxxxxx'
def insert_info(item): # 判斷當主從不同步時用函數把狀態信息寫入系統文件
patt = r'/tmp'
filename = 'slave_jk.txt'
writ = ' '
f = open(patt + '/' + filename, 'a')
writ = writ + time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
writ = writ + item
f.write(writ)
f.close()
# 把當前從庫同步狀態信息取出來放列表中
info = os.popen(mysqlbase + ' -h %s -u%s -p%s -e "show slave status\G"|grep -E "Slave_IO_Running|Slave_SQL_Running|Seconds_Behind_Master|Master_Log_File|Read_Master_Log_Pos|Relay_Master_Log_File|Exec_Master_Log_Pos"' % (host, user, passw)).read()
info_list = info.split()
info_tup = {}
js = 0
_idx = 0
pd = len(info_list) / 2
for idx, item in enumerate(info_list):
js += 1
if js > pd:
continue
info_tup[info_list[_idx]] = info_list[_idx + 1]
_idx += 2
if len(sys.argv) == 1: # 當運行腳本不加參數時給出提示執行腳本格式
print('your can insert python + pyname + Seconds_Behind_Master or file_pos or io_sql')
elif sys.argv[1] == 'Seconds_Behind_Master':
if info_tup['Seconds_Behind_Master:'] == '0':
print(0)
else:
item = 'Seconds_Behind_Master ' + info_tup['Seconds_Behind_Master:']
insert_info(item)
elif sys.argv[1] == 'file_pos':
if info_tup['Master_Log_File:'] == info_tup['Relay_Master_Log_File:'] and info_tup['Read_Master_Log_Pos:'] == info_tup['Exec_Master_Log_Pos:']:
print(0)
else:
item = 'Master_Log_File ' + info_tup['Master_Log_File:'] + ' Relay_Master_Log_File ' + info_tup['Relay_Master_Log_File:'] + ' Read_Master_Log_Pos ' + info_tup['Read_Master_Log_Pos:'] + ' Exec_Master_Log_Pos ' + info_tup['Exec_Master_Log_Pos:']
insert_info(item)
elif sys.argv[1] == 'io_sql':
if info_tup['Slave_IO_Running:'] == 'Yes' or info_tup['Slave_SQL_Running:'] == 'Yes':
print(0)
else:
item = 'Slave_IO_Running ' + info_tup['Slave_IO_Running:'] + ' Slave_SQL_Running ' + info_tup['Slave_SQL_Running:']
insert_info(item)
轉載于:https://www.cnblogs.com/hmysql/p/9057456.html
總結
以上是生活随笔為你收集整理的python脚本 监控MySQL slave 状态的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 这个英语任务型阅读有人可以给一个解析吗(
- 下一篇: 五大经典算法之回溯法