python写的监控mysql主从的app

yllplay

• #!/usr/bin/env python
  
• # -*- coding: utf-8 -*-
  
• #File:repl_wx.py
  
• #creater:wangwei
  
• import MySQLdb
  
• import Queue,os,base64,time,sys,wx,threading
  
• import ConfigParser,logging
  
• from wx.lib.mixins.listctrl import ListCtrlAutoWidthMixin
  
• 
  
• 
  
• class Repl:
  
•     def __init__(self,user,passwd,host,hostname):
  
•         self.user = user
  
•         self.passwd = passwd
  
•         self.host = host
  
•         self.hostname = hostname
  
•     def Slave(self,user,passwd,host,hostname):
  
•         try:
  
•             conn = MySQLdb.connect(host,user = self.user,passwd = self.passwd,connect_timeout = 2)
  
•             cursor = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)
  
•             sql = "SHOW VARIABLES LIKE 'version'"
  
•             cursor.execute(sql)
  
•             alldata = cursor.fetchall()
  
•             version = alldata[0]["Value"].split('.')[0]
  
•             sql = "show slave status"
  
•             cursor.execute(sql)
  
•             alldata = cursor.fetchall()
  
•             IO = alldata[0]["Slave_IO_Running"]
  
•             SQL = alldata[0]["Slave_SQL_Running"]
  
•             if version == "4":
  
•                 Errno = alldata[0]["Last_errno"]
  
•                 Error = alldata[0]["Last_error"]
  
•             else:
  
•                 Errno = alldata[0]["Last_Errno"]
  
•                 Error = alldata[0]["Last_Error"]
  
•             cursor.close()
  
•             conn.close()
  
•             return IO,SQL,Errno,Error
  
•         except:
  
•             return 0,0,0,0
  
• 
  
• class Check:
  
•     def __init__(self,app,user,passwd,host,hostname):
  
•         self.app=app
  
•         self.user = user
  
•         self.passwd = passwd
  
•         self.host = host
  
•         self.hostname = hostname
  
•         boss = Repl(user,passwd,host,hostname)
  
•         IO,SQL,Errno,Error = boss.Slave(self.user,self.passwd,self.host,self.hostname)
  
•         self.IO = IO
  
•         self.SQL = SQL
  
•         self.Errno = Errno
  
•         self.Error = Error
  
•     def Status(self):
  
•         now = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
  
•         if not self.IO and not self.SQL:
  
•             errlist = [self.host,self.hostname,now,'Error:Can not Connect mysql!']
  
•             wx.CallAfter(self.app.ErrorMessage, errlist)
  
•             a = self.hostname +  " " + self.host + " Can not Connect mysql DB!"
  
•             logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(levelname)s %(message)s',datefmt='%Y-%m-%d %H:%M:%S',filename='slave.log',filemode='a')
  
•             logging.error(a)
  
•             return 0
  
•         if self.IO == "Yes":
  
•             if self.SQL == "Yes":
  
•                 #print now + " " + self.hostname + " OK -slave is running " + self.host
  
•                 #errlist = [self.host,self.hostname,now,'OK -slave is running!']
  
•                 #wx.CallAfter(self.app.ErrorMessage, errlist)
  
•                 return 0
  
•             else:
  
•                 #print now + " " + self.hostname + " Critical -slave SQL Error!"
  
•                 errlist = [self.host,self.hostname,now,'Critical -slave SQL Error!']
  
•                 wx.CallAfter(self.app.ErrorMessage, errlist)
  
•                 a = self.hostname +  " " + self.host + " Critical -slave SQL Error!"
  
•                 logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(levelname)s %(message)s',datefmt='%Y-%m-%d %H:%M:%S',filename='slave.log',filemode='a')
  
•                 logging.error(a)
  
•                 return 1
  
•         else:
  
•             if self.SQL == "Yes":
  
•                 #print now + " " + self.hostname + " Critical -slave IO Error!"
  
•                 errlist = [self.host,self.hostname,now,'Critical -slave IO Error!']
  
•                 wx.CallAfter(self.app.ErrorMessage, errlist)
  
•                 a = self.hostname +  " " + self.host + " Critical -slave IO Error!"
  
•                 logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(levelname)s %(message)s',datefmt='%Y-%m-%d %H:%M:%S',filename='slave.log',filemode='a')
  
•                 logging.error(a)
  
•                 return 2
  
•             else:
  
•                 #print now + " " + self.hostname + " Critical -slave IO and SQL Error!"
  
•                 errlist = [self.host,self.hostname,now,'Critical -slave IO and SQL Error!']
  
•                 wx.CallAfter(self.app.ErrorMessage, errlist)
  
•                 a = self.hostname +  " " + self.host + " Critical -slave IO and SQL Error!"
  
•                 logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(levelname)s %(message)s',datefmt='%Y-%m-%d %H:%M:%S',filename='slave.log',filemode='a')
  
•                 logging.error(a)
  
•                 return 3
  
• 
  
• class StartScan(threading.Thread):
  
•     def __init__(self,app):
  
•         threading.Thread.__init__(self)
  
•         self.app = app
  
•         self.timeToQuit = threading.Event()
  
•         self.timeToQuit.clear()
  
•     def stop(self):
  
•         self.timeToQuit.set()
  
•     def run(self):
  
•         self.user,self.passwd,self.hostlist,self.a,self.time = self.conf()
  
•         self.times = 1
  
•         while True:
  
•             threads = []
  
•             if self.timeToQuit.isSet():
  
•                 break
  
•             for i in range(self.a):
  
•                 host = self.hostlist[0]
  
•                 hostname = self.hostlist[1]
  
•                 boss = Check(self,self.user,self.passwd,host,hostname)
  
•                 t = threading.Thread(target=boss.Status,args=())
  
•                 threads.append(t)
  
•             #print 'Total %s Threads is working...' %self.a + '\n'
  
•             msg = u"第" + "%s"%(self.times) + u"次扫描....."
  
•             self.app.CurrentScan(msg)
  
•             for i in range(self.a):
  
•                 threads.start()
  
•                 time.sleep(0.05)
  
•             for i in range(self.a):
  
•                 threads.join()
  
•             self.times += 1
  
•             time.sleep(self.time)
  
•     def CurrentScan(self,msg):
  
•         wx.CallAfter(self.app.CurrentScan, msg)
  
•     def conf(self):
  
•         fp = ConfigParser.ConfigParser()
  
•         fp.readfp(open('repl.ini'))
  
•         iplist = fp.get("global", "iplist")
  
•         user = fp.get("global", "user")
  
•         passwd = fp.get("global", "passwd")
  
•         time = fp.getint("global","time")
  
•         user = base64.decodestring(user)
  
•         passwd = base64.decodestring(passwd)
  
•         hostlist = []
  
•         for i in iplist.split(";"):
  
•             hostlist.append(i.split(","))
  
•         a = len(hostlist)
  
•         return user,passwd,hostlist,a,time
  
•     def ErrorMessage(self,errlist):
  
•         wx.CallAfter(self.app.ErrorMessage, errlist)
  
• 
  
• class ScanUnit(wx.Panel):
  
•     def __init__(self, parent,id=-1,title='',port='',):
  
•         wx.Panel.__init__(self, parent,id)
  
•         self.parent = parent
  
•         self.id = id
  
•         self.title = title
  
•         self.scaning = wx.StaticText(self,-1,label=u"准备扫描……",style = wx.ALIGN_LEFT|wx.ST_NO_AUTORESIZE)
  
•         self.openBtn=wx.Button(self,-1,u'打开日志')
  
•         self.openBtn.SetForegroundColour('red')
  
•         #self.openBtn.SetBackgroundColour('purple')
  
•         self.startBtn=wx.Button(self,-1,u'扫描')
  
•         self.stopBtn=wx.Button(self,-1,u'停止')
  
•         self.stopBtn.Disable()
  
•         self.list = AutoWidthListCtrl(self)
  
•         self.list.SetTextColour("red")
  
•         self.list.InsertColumn(0, 'IP', width=120)
  
•         self.list.InsertColumn(1, u'区组名称', width=100)
  
•         self.list.InsertColumn(3, u'发生时间',width=140)
  
•         self.list.InsertColumn(4, u'返回信息',width=200)
  
•         self.list.DeleteAllItems()
  
•         self.Bind(wx.EVT_BUTTON,self.OnStart,self.startBtn)
  
•         self.Bind(wx.EVT_BUTTON,self.OnStop,self.stopBtn)
  
•         self.Bind(wx.EVT_BUTTON,self.Open,self.openBtn)
  
•         self._layout()
  
•     def _layout(self):  #布局
  
•         action = wx.BoxSizer(wx.HORIZONTAL)
  
•         action.Add(self.scaning,3, wx.ALIGN_CENTER_HORIZONTAL|wx.EXPAND)#对齐没有解决
  
•         action.Add(self.startBtn,1, wx.ALIGN_CENTER_VERTICAL|wx.EXPAND)
  
•         action.Add(self.stopBtn,1, wx.ALIGN_CENTER_VERTICAL|wx.EXPAND)
  
•         action.Add(self.openBtn,1, wx.ALIGN_CENTER_VERTICAL|wx.EXPAND)
  
•         listbox = wx.BoxSizer(wx.HORIZONTAL)
  
•         listbox.Add(self.list, 1, wx.EXPAND)
  
•         self.box = wx.StaticBox(self, self.id, self.title,style = wx.SUNKEN_BORDER)
  
•         self.ScanUnit = wx.StaticBoxSizer(self.box, wx.VERTICAL)
  
•         self.ScanUnit.Add(action, 0, wx.ALL|wx.EXPAND, 2)
  
•         self.ScanUnit.Add(listbox, 5, wx.EXPAND, 2)
  
•         self.SetSizer(self.ScanUnit)
  
•         self.parent.sizer.Add(self,1,wx.EXPAND)
  
•     def OnStart(self,event):
  
•         self.startBtn.Disable()
  
•         self.stopBtn.Enable()
  
•         #self.DeleteItems()
  
•         self.thread=StartScan(self)
  
•         self.thread.setDaemon(True)
  
•         self.thread.start()
  
•         self.scaning.SetLabel(u'正在扫描……')
  
•     def OnStop(self,event):
  
•         self.stopBtn.Disable()
  
•         self.startBtn.Enable()
  
•         self.thread.stop()
  
•         self.scaning.SetLabel(u'停止扫描……')
  
•     def Open(self,event):
  
•         wx.Execute("notepad slave.log")
  
•         #os.system('notepad slave.log')
  
•     def CurrentScan(self,msg): #当前扫描动作
  
•         self.scaning.SetLabel(msg)
  
•     def ErrorMessage(self,errlist):#错误信息
  
•         index = self.list.InsertStringItem(sys.maxint, errlist[0])
  
•         self.list.SetStringItem(index, 1, errlist[1])
  
•         self.list.SetStringItem(index, 2, errlist[2])
  
•         self.list.SetStringItem(index, 3, errlist[3])
  
•         self.list.RefreshItem(index)
  
•     def DeleteItems(self):
  
•         self.list.DeleteAllItems()
  
• 
  
• class AutoWidthListCtrl(wx.ListCtrl, ListCtrlAutoWidthMixin):
  
•     def __init__(self, parent):
  
•         wx.ListCtrl.__init__(self, parent, -1, style=wx.LC_REPORT|wx.LC_HRULES|wx.LC_VRULES)
  
•         ListCtrlAutoWidthMixin.__init__(self)
  
• 
  
• class MainPanel(wx.Panel):
  
•     def __init__(self,parent):
  
•         wx.Panel.__init__(self, parent)
  
•         self.sizer = wx.GridSizer(rows=1,cols=1,hgap = 20,vgap = 15)
  
•         self.aaa = ScanUnit(self,-1,u'<Mysql主从>','8001')
  
•         self.SetSizer(self.sizer)
  
• 
  
• class CreateMenu():#创建菜单
  
•     def __init__(self,parent):
  
•         self.menuBar = wx.MenuBar()
  
•         self.file = wx.Menu()
  
•         self.close = self.file.Append(-1,u'退出(&X)')
  
•         self.menuBar.Append(self.file,u'文件(&F)')
  
•         self.help = wx.Menu()
  
•         self.about = self.help.Append(-1,u'关于(&A)')
  
•         self.menuBar.Append(self.help,u'帮助(&H)')
  
•         parent.SetMenuBar(self.menuBar)
  
• 
  
• class MyFrame(wx.App):
  
•     u'''''Mysql主从监控\nE-mail:wangwei03@gyyx.cn\nQQ:83521260'''
  
•     def OnInit(self):
  
•         self.frame=wx.Frame(parent=None,id=-1,title=u'Mysql主从监控程序',size=(650,450))
  
•         self.frame.SetIcon(wx.Icon('kankan.ico', wx.BITMAP_TYPE_ICO))
  
•         self.panel = MainPanel(self.frame)
  
•         self.frame.Center(direction=wx.BOTH)
  
•         self.menu = CreateMenu(self.frame)
  
•         self.frame.statusBar = self.frame.CreateStatusBar(3)
  
•         #print dir(self.frame.statusBar)
  
•         self.frame.statusBar.SetStatusWidths([-12,-12,-13])
  
•         self.frame.statusBar.SetForegroundColour('purple')
  
•         self.frame.statusBar.SetBackgroundColour('pink')
  
•         self.frame.StatusBar.Font.Bold = True
  
•         #self.frame.StatusBar.Font.Size = 13
  
•         self.frame.StatusBar.SetStatusText(u&quot;好好学习&quot;,0)
  
•         self.frame.StatusBar.SetStatusText(u&quot;天天向上&quot;,1)
  
•         self.timer=wx.PyTimer(self.Notify)
  
•         self.timer.Start(1000)
  
•         self.Notify()
  
•         self.Bind(wx.EVT_MENU,self.OnClose,self.menu.close)
  
•         self.Bind(wx.EVT_MENU,self.OnAbout,self.menu.about)
  
•         self.SetTopWindow(self.frame)
  
•         self.frame.Show()
  
•         return True
  
•     def Notify(self):
  
•         t = time.localtime(time.time())
  
•         st = time.strftime(&quot;%Y-%m-%d %H:%M:%S&quot;,t)
  
•         self.frame.StatusBar.SetStatusText(u&quot;当前系统时间  &quot;+st,2)
  
•     def OnClose(self,event):
  
•         self.frame.Destroy()
  
•     def OnAbout(self,event):
  
•         wx.MessageBox(self.__doc__,'Mysql Replication Status',wx.OK)
  
• 
  
• if __name__ == &quot;__main__&quot;:
  
•     app=MyFrame(None)
  
•     app.MainLoop()
  

　　

　　配置文件的名字为：repl.ini
　　格式为：
　　[global]
　　
user = cmVwbsdfsdfA==
　　
passwd = SGMxNzVBcEdEZ0ZRTGsfdfV6aA==
　　
time = 10
　　
iplist = 192.168.8.11,烟雨江南;192.168.8.12,开天辟地;
　　
#说明：用户名和密码#base64.encodestring()，base64.decodestring()加密和解密，time为设置的超时时间(单位为秒)，iplist为IP和名字列表
　　主要用于批量的mysql丛库服务器状态监控