搜索
首页后端开发Python教程python mysql导库加入主从同步集群实例介绍

脚本可以在任意机器上执行(需要安装mysql,至少是mysql客户端,mysql只能版本为5.6及以上),首先输入源ip,检测源ip上的mysql是否正常运行,再在本机dump mysql数据库,然后将dump文件传输到目的服务器,在目的服务器上导入数据库,最后把从库加入到现用集群中。

[root@master test]# cat finaly_mysql.py

#!/usr/bin/env python

#-*- coding: utf-8 -*-

import MySQLdb, socket, paramiko,sys, os,datetime, time

sour_db=raw_input('please input the source mysql database ip:')

dest_db=raw_input('please input the destination mysql database ip:')

password=raw_input('please input the sour_db root users password :')

def check_port(ip,port):

print "test whether source mysql db is running!"

res=socket.socket(socket.AF_INET, socket.SOCK_STREAM)

res.settimeout(3)

try:

res.connect((ip,port))

print 'Server port 3306 OK!'

print("\033[41;36m  Server port 3306 OK!   \033[0m")

except Exception,e:  

print Exception,":",e

print "break this program"

sys.exit()

res.close()

#查看源库的3306端口是否正常

def begin_dump():

        print "begin dump remote mysql,please waiting...!"

print("\033[41;36m  begin dump remote mysql,please waiting...!   \033[0m")

        hostname=sour_db

        username='root'

        dump='mysqldump -uroot -pXp29at5F37 -h 192.168.3.10 -A -B  > /tmp/dump.sql  && echo $? '

if os.popen(dump).read().strip() == '0':

print "dump result is 0,means dump success"

print("\033[41;36m  dump result is 0,means dump success   \033[0m")

else:

print "\033[1;31;40m%s\033[0m"  % "dump error,exit python file"

sys.exit()

#从本地 dump数据库文件

def trans_dump():

print "   "

local_dir='/tmp' 

        remote_dir='/tmp'

        dest_dir='/tmp'

print " "

print "begin transfer  mysql dump file from local server to destination mysql database server ,please waiting...!"

try:

            t=paramiko.Transport((dest_db,22))

            t.connect(username='root',password=password)

            sftp=paramiko.SFTPClient.from_transport(t)

            files='dump.sql'

            print "\033[1;32;40m%s\033[0m" % "transfer back file,Please wait ...."

            print '    Beginning to transfer file  to  %s  %s ' % (dest_db,datetime.datetime.now())

            print '        Transfering file:',dest_db + ':' + os.path.join(local_dir,files)

            sftp.put(os.path.join(local_dir,files),os.path.join(dest_dir,files))

            t.close()

            print '    transfer All dump file success %s ' % datetime.datetime.now()

        except Exception,e:

            print Exception,"\033[1;31;40m%s\033[0m" % ":", "\033[1;31;40m%s\033[0m" % e

            sys.exit()

#将数据库文件从本地传输到目的服务器,即dest_db

def import_dump():

conn=MySQLdb.connect(host=dest_db,user='root',passwd='Xp29at5F37',db='test')

        cur1=conn.cursor()

        cur1.execute("stop slave;")

        cur1.close()

        cur2=conn.cursor()

        cur2.execute("reset master;")

        cur2.close()

        cur3=conn.cursor()

        cur3.execute("reset slave all;")

        cur3.close()

        conn.close()

print "   "

print "begin to import mysql  dump file   ,please waiting...!"

        local_dir='/tmp'

        remote_dir='/tmp'

        dest_dir='/tmp'

import_command = "mysql -uroot -pleyou  < /tmp/dump.sql"

print  '  begin import dump file ,it may take a long time, please be patient !!!'

try:

ssh =paramiko.SSHClient ()

ssh.load_system_host_keys ()

ssh.connect (hostname =dest_db,username ='root',password =password)

stdin, stdout, stderr = ssh.exec_command (import_command) 

      print stderr.read ()

ssh.close ()

        except Exception,e:

                print Exception,":",e

print "import over"

#导入之前先将dest_db的slave 都停掉,因为不知道dest_db的状态,可能之前是个主库,也可能是其他机子的从库。

def final_check_mysql ():

print "   "

print "finally check mysql service   "

        status = True

        try:

                conn=MySQLdb.connect(host=dest_db,user='root',passwd='Xp29at5F37',db='test')

                cur1=conn.cursor()

                cur1.execute("CHANGE MASTER TO MASTER_HOST='192.168.3.10', MASTER_USER='root', MASTER_PASSWORD='Xp29at5F37', MASTER_AUTO_POSITION=1;")

                cur1.close()

                cur3=conn.cursor()

                cur3.execute("start slave;")

                cur3.close()

print "sleep 10 seconds;"

time.sleep(10)

                cur2=conn.cursor()

                cur2.execute("show slave status;")

                result = cur2.fetchall()

                io_thread= result[0][10]

                sql_thread= result[0][11]

                print io_thread,sql_thread

        if io_thread == "Yes" and sql_thread == "Yes":

                   print 'MySQL master/slave replication status is successfully'

                else:

                   print 'MySQL Master/Slave replication fail,Please check it'

                cur2.close()

                conn.close()

        except Exception,e:

                print Exception,"\033[1;31;40m%s\033[0m" % ":", "\033[1;31;40m%s\033[0m" % e

                status = True

        return status

#最后检查新从库的运行状态,同步是否正常

if __name__ == "__main__":

a=check_port(sour_db,3306)

b=begin_dump()

c=trans_dump()

d=import_dump()

e=final_check_mysql()

print "dump file ok!!!!!!!!!!!"

以上是python mysql导库加入主从同步集群实例介绍的详细内容。更多信息请关注PHP中文网其他相关文章!

声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
Python和时间:充分利用您的学习时间Python和时间:充分利用您的学习时间Apr 14, 2025 am 12:02 AM

要在有限的时间内最大化学习Python的效率,可以使用Python的datetime、time和schedule模块。1.datetime模块用于记录和规划学习时间。2.time模块帮助设置学习和休息时间。3.schedule模块自动化安排每周学习任务。

Python:游戏,Guis等Python:游戏,Guis等Apr 13, 2025 am 12:14 AM

Python在游戏和GUI开发中表现出色。1)游戏开发使用Pygame,提供绘图、音频等功能,适合创建2D游戏。2)GUI开发可选择Tkinter或PyQt,Tkinter简单易用,PyQt功能丰富,适合专业开发。

Python vs.C:申请和用例Python vs.C:申请和用例Apr 12, 2025 am 12:01 AM

Python适合数据科学、Web开发和自动化任务,而C 适用于系统编程、游戏开发和嵌入式系统。 Python以简洁和强大的生态系统着称,C 则以高性能和底层控制能力闻名。

2小时的Python计划:一种现实的方法2小时的Python计划:一种现实的方法Apr 11, 2025 am 12:04 AM

2小时内可以学会Python的基本编程概念和技能。1.学习变量和数据类型,2.掌握控制流(条件语句和循环),3.理解函数的定义和使用,4.通过简单示例和代码片段快速上手Python编程。

Python:探索其主要应用程序Python:探索其主要应用程序Apr 10, 2025 am 09:41 AM

Python在web开发、数据科学、机器学习、自动化和脚本编写等领域有广泛应用。1)在web开发中,Django和Flask框架简化了开发过程。2)数据科学和机器学习领域,NumPy、Pandas、Scikit-learn和TensorFlow库提供了强大支持。3)自动化和脚本编写方面,Python适用于自动化测试和系统管理等任务。

您可以在2小时内学到多少python?您可以在2小时内学到多少python?Apr 09, 2025 pm 04:33 PM

两小时内可以学到Python的基础知识。1.学习变量和数据类型,2.掌握控制结构如if语句和循环,3.了解函数的定义和使用。这些将帮助你开始编写简单的Python程序。

如何在10小时内通过项目和问题驱动的方式教计算机小白编程基础?如何在10小时内通过项目和问题驱动的方式教计算机小白编程基础?Apr 02, 2025 am 07:18 AM

如何在10小时内教计算机小白编程基础?如果你只有10个小时来教计算机小白一些编程知识,你会选择教些什么�...

如何在使用 Fiddler Everywhere 进行中间人读取时避免被浏览器检测到?如何在使用 Fiddler Everywhere 进行中间人读取时避免被浏览器检测到?Apr 02, 2025 am 07:15 AM

使用FiddlerEverywhere进行中间人读取时如何避免被检测到当你使用FiddlerEverywhere...

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
4 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
4 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
4 周前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解锁Myrise中的所有内容
1 个月前By尊渡假赌尊渡假赌尊渡假赌

热工具

适用于 Eclipse 的 SAP NetWeaver 服务器适配器

适用于 Eclipse 的 SAP NetWeaver 服务器适配器

将Eclipse与SAP NetWeaver应用服务器集成。

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

Atom编辑器mac版下载

Atom编辑器mac版下载

最流行的的开源编辑器

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

EditPlus 中文破解版

EditPlus 中文破解版

体积小,语法高亮,不支持代码提示功能