脚本可以在任意机器上执行(需要安装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中文网其他相关文章!

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

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

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

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

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

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

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

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


热AI工具

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

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

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

适用于 Eclipse 的 SAP NetWeaver 服务器适配器
将Eclipse与SAP NetWeaver应用服务器集成。

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)

Atom编辑器mac版下载
最流行的的开源编辑器

Dreamweaver CS6
视觉化网页开发工具

EditPlus 中文破解版
体积小,语法高亮,不支持代码提示功能