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

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

此脚本主要用于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()