Welcome 微信登录

首页 / 数据库 / MySQL / 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（） 
Oracle RMAN 备份命令超详细解释Oracle参数文件的本质相关资讯      MySQL 主从数据库  MySQL 主从切换  MySQL 切换数据库  本文评论 查看全部评论 （1）
表情： 姓名： 字数


评论声明
  • 尊重网上道德，遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款