MySQL数据库主从切换脚本自动化

本文转载自:https://blog.csdn.net/weixin_36135773/article/details/79514507

在一些实际环境中,如何实现主从的快速切换,在没有MHA等工具的辅助下,如何避免影响线上的业务,一般都会在在业务低峰期进行主从切换,本脚本主要利用MySQL自带的命令行工具(FLUSH TABLES WITH READ LOCK)进行锁全库,且由用户自行输入判断多少秒内从库BINLOG数据不在同步后,认为主从数据已达一致性可以进行主从切换(在一些资料上说也可以用READ-ONLY来锁库,但需要注意如果写入用户具有Admin权限是不受限制),主从切换完成5秒后进行检查主从是否同步问题.

连接数据库使用TCP/IP方式,需要相应的操作数据库权限。

目前判断使用show master status 来判断,可以show slave status返回的值来判断,自行修改。

yum install MySQL-python

脚本:switch_master_slave.py

#!/usr/bin/env python
# -*- coding: utf- -*-
import MySQLdb
import time
import sys
class m_s:
    def __init__(self,host,user,password,port):
        self.host=host
        self.user=user
        self.passowrd=password
        self.port=port
    def getConn(self,db="mysql"):
        try:
            conn=MySQLdb.connect(host=self.host, user=self.user, passwd=self.passowrd, db=db, port=self.port, charset="utf8")
            cur = conn.cursor()
            return cur
        except Exception as e:
            return e
    def execSQLlock(self,*args):
        flush_sql="FLUSH TABLES WITH READ LOCK"
        cur.execute(flush_sql)
    def execIo(self,cur,command):
        cur.execute(command)
        db_pos = cur.fetchall()
        for value in db_pos:
            value=value
        return value
    def exeStop(self,cur,command):
        cur.execute(command)
        db_pos = cur.fetchall()
        return db_pos
    def execSQLstatus(self,*args):
        n=
        self.execSQLlock(cur)
        flush_m = "flush logs"
        cur.execute(flush_m)
        while True:
            data=[]
            slave_pos=[]
            n=n+
            exe_sql = "select Command,State,Info,Id from information_schema.processlist"
            cur.execute(exe_sql)
            plist = cur.fetchall()
            for li in range(len(plist)):
                ] == ] == "Waiting for global read lock":
                    lock_id = ])
                    print plist[li][]
                    cur.execute(lock_id)
            slave_pos.append(self.execIo(cur1, ])
            data.append(self.execIo(cur1,]) ##从库的游标
            )
            slave_pos.append(self.execIo(cur1, ])
            data.append(self.execIo(cur,])##从库的游标
            print ".......",data,slave_pos
            ]==data[] and slave_pos[]==slave_pos[]:
                try:
                    print "第%s次判断数据已经同步....."%n
                    if n==c_time:
                        print "开始主从切换工作........"
                        self.exeStop(cur1,"stop slave") ##停止从库同步
                        new_pos=self.exeStop(cur1,"show master status")#获取新主库的FILE和POS的值,游标为还没切换前的从库
                        #print "获取新主库的FILE和POS的值,游标为还没切换前的从库",new_pos
                        self.exeStop(cur,"reset master;")##主库释放从库主从信息......
                        ##在从库执行new_change 指向新的主库
                        self.exeStop(cur1,"reset slave all")
                        new_change=])+]+]+])+][])+][])
                        print new_change
                        self.exeStop(cur,new_change)##在原来主库上执行change master to.....
                        #print "在原来主库上执行change master to...."
                        self.exeStop(cur,"start slave")  ##在原来主库上执行change master to.....
                        )
                        s_pos=self.exeStop(cur,"show slave status;")
                        #print s_pos[][],s_pos[][]
                        ][]==][]=="Yes":
                            self.exeStop(cur1,"reset slave all")
                            print  "主从切换成功!"
                            print "\n"
                            while True:
                                print "等待其他操作完成,即将unlock tables主库......"
                                try:
                                    stop = raw_input("输入终止命令q即完成此次操作:\n")
                                    if stop == "q":
                                        sys.exit()
                                        # break
                                except Exception as e:
                                    print "good bye"

                        else:
                            print   s_pos[][]
                        break
                except Exception as e:
                    return e
            else:
                print "主从数据未达到一致性..........",n
                n=
                data=[]

if __name__ =="__main__":
    c_time=int(raw_input("多少秒后进行主从切换..>>"))
    print "****************************************************\n"

    print "请根据提示输入指定信息:"
    m_host = raw_input("目前主库的地址:")
    m_user = raw_input("目前主库的登陆用户名:")
    m_password = raw_input("目前主库的密码:")
    m_port = int(raw_input("目前主库的端口:"))
    print "****************************************************\n"
    s_host = raw_input("目前从库的地址:")
    s_user = raw_input("目前从库的登陆用户名:")
    s_password = raw_input("目前从库的密码:")
    s_port = int(raw_input("目前从库的端口:"))
    M = m_s(m_host, m_user, m_password, m_port)
    S = m_s(s_host,s_user,s_password,s_port)
    cur = M.getConn()  ##获取主库游标
    cur1 = S.getConn()  ##获取从库游标
    print "*****************************************************\n"
    print "主从同步用户信息.........\n"
    s_user1 = raw_input("输入主从同步的用户>>:")
    s_password1 = raw_input("输入主从同步的密码:")
    s_port1 = int(raw_input("输入主从同步的端口:"))

    M.execSQLstatus(cur,s_host,s_user1,s_password1,s_port1)
# python switch_master_slave.py
多少秒后进行主从切换..>>
****************************************************

请根据提示输入指定信息:
目前主库的地址:192.168.56.100
目前主库的登陆用户名:wanbin
目前主库的密码:mysql
目前主库的端口:
****************************************************

目前从库的地址:192.168.56.200
目前从库的登陆用户名:wanbin
目前从库的密码:mysql
目前从库的端口:
*****************************************************

主从同步用户信息.........

输入主从同步的用户>>:repl
输入主从同步的密码:wanbin
输入主从同步的端口:
....... [234L, 234L] [250L, 250L]
第1次判断数据已经同步.....
....... [234L, 234L] [250L, 250L]
第2次判断数据已经同步.....
....... [234L, 234L] [250L, 250L]
第3次判断数据已经同步.....
....... [234L, 234L] [250L, 250L]
第4次判断数据已经同步.....
....... [234L, 234L] [250L, 250L]
第5次判断数据已经同步.....
开始主从切换工作........
change master to master_host=,MASTER_LOG_FILE=
switch_master_slave.py:: Warning: Sending passwords in plain text without SSL/TLS is extremely insecure.
  cur.execute(command)
switch_master_slave.py:: Warning: Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information.
  cur.execute(command)
主从切换成功!

等待其他操作完成,即将unlock tables主库......
输入终止命令q即完成此次操作:

等待其他操作完成,即将unlock tables主库......
输入终止命令q即完成此次操作:
    q
等待其他操作完成,即将unlock tables主库......
输入终止命令q即完成此次操作:
q

MySQL数据库主从切换脚本自动化的更多相关文章

  1. Spring AOP实现Mysql数据库主从切换(一主多从)

    设置数据库主从切换的原因:数据库中经常发生的是“读多写少”,这样读操作对数据库压力比较大,通过采用数据库集群方案, 一个数据库是主库,负责写:其他为从库,负责读,从而实现读写分离增大数据库的容错率.  ...

  2. mysql+keepalived主从切换脚本 转

    Keepalived MySQL故障自动切换脚本   MySQL架构为master-slave(主从),master故障自动切换到slave上.当然也可以设置为双master,但这里有个弊端:就是当主 ...

  3. (转)Mysql数据库主从心得整理

    Mysql数据库主从心得整理 原文:http://blog.sae.sina.com.cn/archives/4666 管理mysql主从有2年多了,管理过200多组mysql主从,几乎涉及到各个版本 ...

  4. Linux下定时备份MySQL数据库的Shell脚本

    Linux下定时备份MySQL数据库的Shell脚本   对任何一个已经上线的网站站点来说,数据备份都是必须的.无论版本更新还是服务器迁移,备份数据的重要性不言而喻.人工备份数据的方式不单耗费大量时间 ...

  5. mysql数据库主从同步

    环境: Mater:   CentOS7.1  5.5.52-MariaDB  192.168.108.133 Slave:   CentOS7.1  5.5.52-MariaDB  192.168. ...

  6. mysql数据库主从同步读写分离(一)主从同步

    1.mysql数据库主从同步读写分离 1.1.主要解决的生产问题 1.2.原理 a.为什么需要读写分离? 一台服务器满足不了访问需要.数据的访问基本都是2-8原则. b.怎么做?  不往从服务器去写了 ...

  7. MySQL数据库主从同步延迟分析及解决方案

    一.MySQL的数据库主从复制原理 MySQL主从复制实际上基于二进制日志,原理可以用一张图来表示: 分为四步走: 1. 主库对所有DDL和DML产生的日志写进binlog: 2. 主库生成一个 lo ...

  8. mysql数据库分库备份脚本

    mysql数据库分库备份脚本 版本1 for dbname in `mysql -uroot -poldboy123 -e "show databases;" |grep -Evi ...

  9. Linux下MySQL数据库主从同步配置

    说明: 操作系统:CentOS 5.x 64位 MySQL数据库版本:mysql-5.5.35 MySQL主服务器:192.168.21.128 MySQL从服务器:192.168.21.129 准备 ...

随机推荐

  1. LeetCode 7 Reverse Integer int:2147483647-2147483648 难度:2

    https://leetcode.com/problems/reverse-integer/ class Solution { public: int inf = ~0u >> 1; in ...

  2. HangOver

    HangOver Time Limit: 2000/1000 MS (Java/Others)    Memory Limit: 65536/32768 K (Java/Others)Total Su ...

  3. redis消息队列

    http://blog.csdn.net/21aspnet/article/details/7455032

  4. NOI2013 树的计数

    题目:http://uoj.ac/problem/122 85%做法: 动态规划. 首先重编号,BFS序变成1...n,然后DFS序相应重编号. 记pos[i]为i号点在DFS中的位置,即pos[d[ ...

  5. log4cxx 使用代码进行配置

    (1)官网的一个例子 #include <log4cxx/logger.h> #include <log4cxx/helpers/pool.h> #include <lo ...

  6. [ 面试没回答上的问题2]IOS上给body绑定click事件的bug

    面试被问到ios上的bug,自己提到绑定click事件的bug,但是并没有把问题讲的很清楚,这里再清理一下思路. 这个bug只在IOS上有,包括ihone,ipad,由于ios浏览器都用的safari ...

  7. centos7系统下hostname解析

    hostnamectl 是在 centos7以上版本 中新增加的命令,它是用来修改主机名称的,centos7 修改主机名称会比以往容易许多. 首先了解下这个命令 # hostnamectl -h -h ...

  8. Javascript面向

    一.前言 面向对象:专注于由哪一个对象来解决这个问题,编程特点是出现了一个类,从类中拿到对象,由这个对象去解决具体问题.       对于调用者来说,面向过程需要调用者自己去实现各种函数.而面向对象, ...

  9. [总结]Jquery api 快速参考

    选择符 匹配 * 所有元素 #id 带有给定ID的元素 element 给定类型的所有元素,比如说html标签 .class 带有给定类的所有元素 a,b 匹配a或者匹配b的元素 a b 作为a后代的 ...

  10. 每秒查询率QPS

    每秒查询率QPS是对一个特定的查询服务器在规定时间内所处理流量多少的衡量标准,在因特网上,作为域名系统服务器的机器的性能经常用每秒查询率来衡量. 原理:每天80%的访问集中在20%的时间里,这20%时 ...