基于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
投稿猜你喜欢
- 本文实例讲述了php实现的验证码文件类。分享给大家供大家参考。具体如下：<?php/*** @file* @version 1.0*
- 日期是许多 JavaScript 应用程序的基本组成部分，无论是在网页上显示当前日期还是处理用户输入以安排事件。但以清晰一致的格式显示日期对
- 官网上关于组件继承分为两大类，全局组件和局部组件。无论哪种方式，最核心的是创建组件，然后根据场景不同注册组件。有一点要牢记，“Vue.js
Springboot连接数据库第一步springboot继承Mybatis及数据库连接依赖（上一篇文章已经记录 ) 第二步reso- 本文实例为大家分享了JavaScript实现点击出现子菜单的具体代码，供大家参考，具体内容如下首先让我们看一下点击出现子菜单的效果如下图：点
- 也不一定，以前从来没有深入的研究过sql查询，最近买了一本T-SQL查询的书，把以前忽视的问题都记录一下 以前一直模模糊糊的把sqlserv
- python的数据类型可变不可变1、什么是可变不可变首先说一下什么是Python数据的可变不可变。我们都知道定义变量的时候，是先创建一块内存
- 项目需要，做一个和今日头条一样的导航栏，可以横行滚动，幸好再weui里面看到了类似的例子地址：https://weui.shanliwawa
- django orm 有个defer方法，指定模型排除的字段。如下返回的Queryset, 排除‘username', 'i
- 正则表达式处理花括号内容替换赋值@Test public void replaceStr() { &
- 父组件处理：<template> <div class="wrap">
- 前言前几天在Python交流群里边，大佬分享了一个有趣的代码，用于定时发送菜谱分享，觉得挺有意思，这里拿出来给大家分享。实现思路实现思路倒是
- 本文实例为大家分享了python3 smtplib发送邮件的具体代码，供大家参考，具体内容如下smtplib模块是smtp简单邮件传输协议客
- 通常来说，Python的变量/数据类型非常多，但是它是不需要用户指定的，因为有些是根据部份系统函数生成，另外一些是自动根据变量的值识别的，这
- 1.冒泡排序，相邻位置比较大小，将比较大的（或小的）交换位置def maopao(a): for i in ran
- 1．问题描述请编写程序，实现以下功能：在字符串中的所有数字字符前加一个“$”符号。例如，输入A1B2
- python自定义异常实例详解 本文通过两种
- 弹出框有两种：页面弹出框（可定位元素能操作）、Windows弹出框（不能直接定位）一、页面弹出框等待弹出框出现之后，定位弹出框，操作其中元素
- Web_THBC 为表示层也就是页面（.aspx） BLL_THBC 为业务逻辑层 DAL_THBC 为数据库交互层 （向数据库执行SQL语
- 制作这个播放器的目的是为了将下载下来的mp3文件进行随机或是顺序的播放。选择需要播放的音乐的路径，选择播放方式，经过测试可以完美的播放本地音
