Introduction à l'exemple de connexion au cluster de synchronisation maître-esclave avec la bibliothèque python mysql

Le script peut être exécuté sur n'importe quelle machine (mysql doit être installé, au moins le client mysql, mysql ne peut être que la version 5.6 et supérieure), entrez d'abord l'adresse IP source, vérifiez si mysql sur l'adresse IP source fonctionne normalement , puis exécutez-le sur cette machine. Videz la base de données mysql, puis transférez le fichier de vidage vers le serveur de destination, importez la base de données sur le serveur de destination et enfin ajoutez la base de données esclave au cluster actif.

[root@master test]# cat finaly_mysql.py

#!/usr/bin/env python

#-*- codage : utf-8 -*-

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

sour_db=raw_input('veuillez saisir l'adresse IP de la base de données mysql source :')

dest_db=raw_input ("Veuillez saisir l'adresse IP de la base de données MySQL de destination :")

password=raw_input('Veuillez saisir le mot de passe de l'utilisateur root sour_db :')

def check_port(ip,port):

print "tester si la base de données mysql source est en cours d'exécution!"

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

res.settimeout(3)

essayez :

res.connect((ip,port))

print 'Port du serveur 3306 OK !'

print("

dest_dir='/tmp'

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

print 'commencer l'importation du fichier de vidage, cela peut prendre un certain temps temps, s'il vous plaît soyez patient !!!'

essayez :

ssh =paramiko.SSHClient ()

ssh.load_system_host_keys ()

ssh.connect (nom d'hôte =dest_db, nom d'utilisateur = 'root', mot de passe = mot de passe)

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

print stderr.read ()

ssh.close ()

except Exception,e:

print Exception,":",e

print "import over"

#import Avant, nous arrêtions tous les esclaves de dest_db car nous ne connaissons pas l'état de dest_db. Il s'agissait peut-être d'une base de données maître auparavant, ou d'une base de données esclave d'autres machines.

def final_check_mysql ():

print " "

print "vérifiez enfin le service mysql "

status = True

essayez :

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

conn=conn.cursor()

                                                                                                  Cur1 .close()

                                                                                                                ,                                                 10 secondes ;                                                                                                                        result = cur2.fetchall()

io_thread= result[0][10]

              sql_thread= result[0][11]

                                                    _thread,sql_thread

Si IO_THREAD == "OUI" et SQL_THREAD == "OUI":

IMPRIMER 'L'état de la réplication MySQL MASTER/SLAVE est réussi'

Sinon:

Imprimer 'Échec de la réplication MySQL maître/esclave, veuillez le vérifier'

                                                                                                                                                                                                                                                                                print Exception,"

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!