python mysql连接池 知乎_使用python脚本部署mariadb主从架构
环境准备
一个脚本自动部署master服务 另一个部署slave服务 关闭主从节点的防火墙 以及事先设置好root远程登陆的权限。 grant all on *.* to root@'%' identified by 'root' ;
master
import paramiko
ssh=paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname='192.168.253.168',port=22,username='root',password='root')
a="sed -i -e '12aserver_id=1' -e '13alog_bin=mysql_bin' /etc/my.cnf.d/server.cnf"
b= 'systemctl restart mariadb'
c='''mysql -uroot -proot -e "grant replication slave on *.* to 'slave'@'%' identified by 'slave'"'''
d='''mysql -uroot -proot -e "show master status" '''
当然也可以将abcd四条命令写入一个列表,使用for语句循环出来放入下面命令执行。
stdin,stderr,stdout=ssh.exec_command(d) #将abcd分别执行
res = stdout.read().decode('utf-8') + stderr.read().decode('utf-8')
print(res)
运行显示结果:
sed -i -e '12aserver_id=1' -e '13alog_bin=mysql_bin' /etc/my.cnf.d/server.cnf
systemctl restart mariadb
mysql -uroot -p1 -e "grant replication slave on *.* to 'slave'@'%' identified by 'slave'"
mysql -uroot -p1 -e "show master status"
File Position Binlog_Do_DB Binlog_Ignore_DB
mysql_bin.000012 887350
在linux端查看是否配置成功。
注:mysql -uroot -p1 -e 此命令可以使用paramiko模块直接执行sql语句。e是edit的意思。
当然,也可以使用pymsql模块连接mysql数据库然后利用cur游标里封装的execute方法来执行sql语句,但是可能在执行给与权限的命令时会报错,因为远程登陆并没有权限这么做。
slave
如下的file变量和port变量在master节点会变动,特别时重启数据库后。 如果查看slave status,显示: Slave_IO_Running: No Slave_SQL_Running: No 或者一个YES一个connecting的话,这是因为主节点的master状态发生了变化或者两台主机的某一台防火墙没有关闭。
master_ip = '192.168.253.168'
log_file='mysql_bin.000012'
pos=887350
import paramiko
ssh=paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname='192.168.253.167',port=22,username='root',password='root')
a="sed -i '12aserver_id=2' /etc/my.cnf.d/server.cnf"
b='systemctl restart mariadb'
c='''mysql -uroot -proot -e "CHANGE MASTER TO MASTER_HOST='%s', MASTER_USER='slave', MASTER_PASSWORD='slave', MASTER_LOG_FILE='%s', MASTER_LOG_POS=%s" ''' % (master_ip,log_file,pos)
d="mysql -uroot -proot -e 'start slave'"
stdin,stderr,stdout=ssh.exec_command(d) #将abcd分别执行
res = stdout.read().decode('utf-8') + stderr.read().decode('utf-8')
print(res)
如果报错:The server is not configured as slave; fix in config file or with CHANGE MASTER TO
原因一:配置文件没有添加server_id=2,或者添加完没有成功重启。
原因二:mysql -uroot -p1 -e "CHANGE MASTER TO MASTER_HOST='%s', MASTER_USER='slave', MASTER_PASSWORD='slave', MASTER_LOG_FILE='%s', MASTER_LOG_POS=%s" ''' % (master_ip,log_file,pos)
这条命令没有执行成功,但注意这条命令不成功不会报错,怎么检测呢,可以粘贴脚本的这条命令到终端上执行试试看能否成功。
结果显示:
检测: 在主节点创建一个数据库,并在从节点数据库中查看是否同步上。
Master
slave
666!阿里巴巴内部P8技术专家面试题汇总已备好,看看你会几道吧!!mp.weixin.qq.com
原创作者:四次元猪肉佬
python mysql连接池 知乎_使用python脚本部署mariadb主从架构相关推荐
- mysql连接池源码_一个JAVA数据库连接池实现源码
原文链接:http://www.open-open.com/lib/view/open1410875608164.html // // 一个效果非常不错的JAVA数据库连接池. // from:htt ...
- mysql连接池永驻_【学习笔记】Oracle连接池 数据库常驻连接池(Database Resident Connection Pool)案例介绍...
天萃荷净 分享一篇关于应用程序与Oracle数据库连接的连接方法介绍,数据库常驻连接池(Database Resident Connection Pool)案例介绍 一.介绍常驻连接池(Databas ...
- mysql连接池的原理_数据库连接池的实现及原理
对于一个简单的数据库应用,由于对于数据库的访问不是很频繁.这时可以简单地在需要访问数据库时,就新创建一个连接,用完后就关闭它,这样做也不会带来什么明显的性能上的开销.但是对于一个复杂的数据库应用,情况 ...
- python mysql l链式查询_使用python flask sqlacalchemy orm在PostgreSQL中联接查询
如果您喜欢编写常规的SQL语句,那么为什么不使用SQLAlchemy来完成这项工作呢?你不需要使用像这样的链式方法 join , filter_by 等来查询数据库. 为了回答这个问题,我需要对你的 ...
- mysql多个字符串连接池_使用Coroutine\Channel实现一个简单的MySQL连接池
Channel通道,类似于go语言的chan,支持多生产者协程和多消费者协程,Swoole底层自动实现了协程的切换和调度 Channel实现原理 通道与PHP的Array类似,仅占用内存,没有其他额外 ...
- easyswoole数据库连接池_如何在 Swoole 中优雅的实现 MySQL 连接池
如何在 Swoole 中优雅的实现 MySQL 连接池 一.为什么需要连接池 ? 数据库连接池指的是程序和数据库之间保持一定数量的连接不断开, 并且各个请求的连接可以相互复用, 减少重复连接数据库带来 ...
- swoole mysql 连接数_用swoole简单实现MySQL连接池
MySQL连接池 在传统的网站开发中,比如LNMP模式,由Nginx的master进程接收请求然后分给多个worker进程,每个worker进程再链接php-fpm的master进程,php-fpm再 ...
- mysql odbc连接池_Java Mysql连接池配置和案例分析--超时异常和处理
前言: 最近在开发服务的时候, 发现服务只要一段时间不用, 下次首次访问总是失败. 该问题影响虽不大, 但终究影响用户体验. 观察日志后发现, mysql连接因长时间空闲而被关闭, 使用时没有死链检测 ...
- golang mysql连接池原理_redis mysql 连接池 之 golang 实现
1 mysql 连接池代码 package lib import ( "database/sql" "fmt" "strconv" &quo ...
最新文章
- 算法学习的链接(持续更新)
- python十六:lambda匿名函数
- session很快失效_一口气说出 4 种分布式一致性 Session 实现方式,面试杠杠的~
- 34观察者模式(Observer Pattern)
- 斯坦福所倡导的设计思维_针对高科技项目的有效开发商倡导
- Hibernate-注解-实体类
- 转---Oracle10G的Sga_max_size和sga_target应该如何设置啊!
- SQL分页查询,SQL的LIMIT语句用法,SQL如何实现分页查询,SpringBoot实现分页查询。
- eXtremeComponents(简称ec)是一系列提供高级显示的开源JSP定制标签
- java jre 32位_jre 1.8 32位
- 使用python做一个翻译工具
- 直流电机开发笔记3—PI调节器的数字实现(代码/仿真)
- 第14届蓝桥杯STEMA测评真题剖析-2022年11月27日Scratch编程初中级组
- java赛马游戏,用JAVA语言实现赛马游戏
- 刀头剑首!产品经理是个危险的职业!
- INH-RFP-BSA-NPs载INH和RFP白蛋白纳米粒/载卡巴他赛的白蛋白纳米粒的制备
- Java实现简单的倒排索引
- AAAI2020 A pre-training based personalized dialogue generation model with persona-sparse data
- 一些多元逐步回归的注意事项
- 5000词学英语——DAY8