MySQL数据库主从正常切换IP脚本

谁还不是小白鼠 2012-11-06

此脚本主要用于mysql数据库主从在正常情况下,因某种原因需要切换IP的情况下使用,主要就是切换IP,主要是通过内网切换公网IP,脚本代码如下:

  1. #!/usr/bin/env python  
  2. # -*- coding: utf-8 -*-  
  3. #script used in Slave Server for change server ip  
  4. import os,sys,time,socket,paramiko,MySQLdb  
  5.  
  6. def mysql_connect(ip,sql):#数据库连接  
  7.     try:  
  8.         conn = MySQLdb.connect(host = ip,user = 'repl',passwd = 'VQrtetr8',connect_timeout=5)  
  9.         cursor = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)  
  10.         cursor.execute(sql)  
  11.         alldata = cursor.fetchall()  
  12.         return alldata  
  13.     except MySQLdb.Error,e:  
  14.         return e.args[0]  
  15.  
  16. def ssh_conm(conm):#连接主库服务器并执行命令  
  17.     host = mysql_connect('127.0.0.1',"show slave status")[0]["Master_Host"]  
  18.     #stat = mysql_chcek(host)  
  19.     username='root' 
  20.     password = '3141315' 
  21.     port = 63008 
  22.     s=paramiko.SSHClient()  
  23.     s.set_missing_host_key_policy(paramiko.AutoAddPolicy())  
  24.     s.connect(host,port,username,password)  
  25.     stdin,stdout,stderr=s.exec_command(conm)  
  26.     result = stdout.read()  
  27.     s.close()  
  28.     return result  
  29.  
  30. def log_pos():#获取当前主从的同步位置  
  31.     result = mysql_connect('127.0.0.1',"show slave status")  
  32.     host = result[0]["Master_Host"]  
  33.     s_log = result[0]["Relay_Master_Log_File"].split('.')[1]  
  34.     s_pos = result[0]["Exec_master_log_pos"]  
  35.     result = mysql_connect(host,"show master status")  
  36.     if result == 2003:#这里是应对mysql数据库无法连接,可以选择据继续和终止脚本  
  37.         choose = raw_input('Can not connect Master,Do you go on ?  (y or n) :')  
  38.         if choose == 'y':  
  39.             return 0,0,0,0 
  40.         else:  
  41.             sys.exit(1)  
  42.     m_log = result[0]["File"].split('.')[1]  
  43.     m_pos = result[0]["Position"]  
  44.     return s_log,m_log,s_pos,m_pos  
  45.  
  46. def show():#循环5次判断主从同步是否一致  
  47.     print "Check Master-Slave now..." 
  48.     for i in range(5):  
  49.         s_log,m_log,s_pos,m_pos = log_pos()  
  50.         if s_log == m_log and s_pos == m_pos:  
  51.             print "Slave and Master is OK." 
  52.             break 
  53.         else:  
  54.             print "Slave and Master not OK,please wait moment." 
  55.             if i == 4:  
  56.                 #print "Must be show Replcation Error,Quit this script now !"  
  57.                 choose = raw_input('Master-slave not synchronous,Do you go on ?  (y or n) :')  
  58.                 if choose == 'y':  
  59.                     break 
  60.                 else:  
  61.                     sys.exit(1)  
  62.             i = i + 1 
  63.             time.sleep(5)  
  64.  
  65. def replace():  
  66.     #显示当前主从的IP,并检测主从3306是否存在  
  67.     print "Before switching IP:" 
  68.     s_ip = os.popen("cat /etc/sysconfig/network-scripts/ifcfg-eth0|grep IPADDR|awk -F '=' '{print $2}'").read().split()[:1][0]  
  69.     print "s_ip: " + s_ip  
  70.     conm = "cat /etc/sysconfig/network-scripts/ifcfg-eth0|grep IPADDR|awk -F '=' '{print $2}'" 
  71.     m_ip = ssh_conm(conm).split()[:1][0]  
  72.     print "m_ip: " + m_ip  
  73.     print 
  74.     #1:停用主的网卡  
  75.     conm = "ifdown eth0" 
  76.     ssh_conm(conm)  
  77.     #2: 判断主从同步是否一致,如果一致则切换,不一致则手动查看问题所在(不一致的情况重复检测5次,间隔5s,检测五次依然不同步可以选择停止脚本的执行或继续执行)  
  78.     show()  
  79.     #3:修改从IP为主的IP  
  80.     os.popen("sed -i 's/%s/%s/' /etc/sysconfig/network-scripts/ifcfg-eth0" % (s_ip,m_ip))  
  81.     print "Slave change IP is OK" 
  82.     #4:修改主IP为从的IP  
  83.     conm = "sed -i 's/%s/%s/' /etc/sysconfig/network-scripts/ifcfg-eth0" % (m_ip,s_ip)  
  84.     ssh_conm(conm)  
  85.     print "Master change IP is OK" 
  86.     #5: 显示替换之后主从的IP  
  87.     print 
  88.     print "After switching IP:" 
  89.     s_ip = os.popen("cat /etc/sysconfig/network-scripts/ifcfg-eth0|grep IPADDR|awk -F '=' '{print $2}'").read().split()[:1][0]  
  90.     print "s_ip: " + s_ip  
  91.     conm = "cat /etc/sysconfig/network-scripts/ifcfg-eth0|grep IPADDR|awk -F '=' '{print $2}'" 
  92.     m_ip = ssh_conm(conm).split()[:1][0]  
  93.     print "m_ip: " + m_ip  
  94.     #6: 停止主从同步  
  95.     mysql_connect("127.0.0.1","slave stop")  
  96.     print "Slave stop OK" 
  97.     #7: 重启用主从的网卡  
  98.     print 
  99.     print "Network service restart now,please wait ......" 
  100.     conm = "ifup eth0" 
  101.     ssh_conm(conm)  
  102.     os.system("ifdown eth0")  
  103.     os.system("ifup eth0")  
  104.     print "Network reatrt OK !" 
  105.  
  106. if __name__ == "__main__":  
  107.     replace() 

相关推荐