基于python的mysql复制工具详解
作者：yangyidba 发布时间：2023-06-24 01:08:28
一 简介
python-mysql-replication 是基于python实现的 MySQL复制协议工具，我们可以用它来解析binlog 获取日志的insert，update，delete等事件 ，并基于此做其他业务需求。比如数据更改时失效缓存，监听dml事件通知下游业务方做对应处理。
其项目信息
二 实践
2.1 安装配置
获取源代码
git clone http://www.github.com/noplay/python-mysql-replication
使用pip 安装
pip install mysql-replication
权限: 可以直接使用复制账号也可以使用其他账号，但是该账号必须 SELECT, REPLICATION SLAVE, REPLICATION CLIENT 权限
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON . TO 'replicator'@'％' IDENTIFIED BY 'xxxxx';
数据库日志相关的参数设置如下:
log_bin=on ，binlog_format=row，binlog_row_image=FULL
2.2 核心类介绍
python-mysql-replication 的入口是类BinLogStreamReader()，我们在使用该工具时需要实例化一个BinLogStreamReader()对象 stream， BinLogStreamReader 通过 ReportSlave 向主库注册作为一个slave角色，用于接受MySQL的binlog广播 。有兴趣的可以研究其代码具体实现。
该实例提供解析 binlog 各种事件的集合，每个事件也是一个对象。
初始化BinLogStreamReader()实例需要使用的参数如下:
2.3 如何使用呢？
最简单的用法 脚本名 pyreplica.py
开启两个窗口，一个窗口执行，另外一个窗口操作mysql 写入或者修改数据
python pyreplica.py
输出如下:
2.3 拓展
基于该工具提供的日志事件解析我们可以做很多事情，比较有名的工具 binlog2sql 利用该工具解析binlog 做数据回滚 。
mysql-replication.py
执行脚本结果 如下图
除了解析binlog，我们还可以用python-mysql-replication 做数据全量加增量迁移。比如仅仅迁移某些大表而不是整个库的时候，可以用到。有兴趣的朋友可以想想大概的算法。
总结
以上所述是小编给大家介绍的基于python的mysql复制工具,网站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！
来源：https://mp.weixin.qq.com/s
0
投稿猜你喜欢
- 在 Python 中，函数可以通过以下语法定义和使用：def function_name(parameter1, parameter2, .
1. auth介绍Django 自带一个用户验证系统。它负责处理用户账号、组、权限和基于cookie的用户会话。认证系统由以下部分- 以下的文章主要是介绍SQL Server数据转换服务的4妙用之执行一些自动化的操作。在SQL Server数据库的实际操作管理中，数据库管理
- 先看一个实例这是我用asp写的一个搜索一个字符串里面第一张图片地址的函数（当然你可以将values那里换一个得到所有图片地址）functio
- scrapy框架概述：Scrapy，Python开发的一个快速,高层次的屏幕抓取和web抓取框架，用于抓取web站点并从页面中提取结构化的数
- 在Intel的早期，Andy Grove遇到一个雇员 - 他建议公司在芯片的基础上开发个人计算机。AndyGrove疑问道“个人计算机能做什
- 有的时候，操作大文件，或者取数，要很久，我们给脚本首尾添加一段代码就知道，这段代码整体的大致运行时间了。import timestart =
- 之前用 copy 不多，本以为它是个很方便的函数，没想到在做练习题时竟还是被它坑了。是我对他期望太多了。func copy(dst, src
- 北京时间2月15日据国外媒体报道，美国知名sns网站Facebook全球活跃用户量已突破1.75亿大关。数据显示，全球20％的网民都使用Fa
- 前言最近遇到的几个网站在提交密码时提交的已经是密文，也就是说在网络上传输的密码是密文，这样提升了密码在网络传输中的安全性。后端语言加解密已
- 0、背景今天看到了一个比较诡异的写法，for后直接跟了else语句，起初还以为是没有缩进好，查询后发现果然有这种语法，特此分享。之前写过c+
- 判断一个数是否能被另一个整数整除是一个挺简单的问题，一般一个模运算就可以搞定了，懒惰的晓萌还是不想自己做，于是找到你帮他写代码，你就帮帮他吧
- FCKeditor的样式设置涉及到了两个文件，一个是你定义好的样式表文件.css，另一个是告诉fck样式表如何使用的xml文件，两个文件确一
- asp之家注：学习javascript(js),免不了要用到打开新窗口，方法很多，总的来说是使用window.open。不同与HTML中的t
- 使用SQL SERVER的[导入]功能,便可将access数据转换,但要注意原来的'自增字段'需要修改,将相应字段标识修改为
- 无论何时，IE总是让页面制作者感到那么的黯然销魂，尤其是IE6，IE7次之，虽然IE8已经做了很大的改进，但由于XP用户的数量实在太大，而且
- 原理：建一个栈，每次碰到一个新标签，就与栈顶的标签配对，如果配对，栈顶的标签就出栈，如果不配对，这个新标签就进栈，最终，栈如果是空的，说明所
- 我们用session来实现这一设想。由于session是用户级的全局变量，将登录的信息记录到session中后，用户就可直接浏览这些特定的页
- sklearn的cross_validation包中含有将数据集按照一定的比例，随机划分为训练集和测试集的函数train_test_spli
- [前言] 我们经常会遇到多重查询问题，而长长的SQL语句往往让人丈二和尚摸不着头脑。特别是客户端部分填入
