小编给大家分享一下如何提取MySQL binlog中指定表的操作记录,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

创新互联坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站制作、成都网站建设、外贸营销网站建设、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的威远网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
一段简单的Python脚本,需要本地装了合适版本的mysqlbinlog工具。
支持Python 2.7+
点击(此处)折叠或打开
- #_*_ coding:utf-8 _*_ 
- import sys 
- import os 
- import io 
- binlogfile = sys.argv[1] 
- database_name = sys.argv[2] 
- table_name = sys.argv[3] 
- def format_binlog(): 
- os.system('mysqlbinlog --base64-output=decode-rows -v '+binlogfile+'>'+binlogfile+'.txt') 
- def pickupbinlog(): 
- f = io.open(binlogfile+'.txt','r') 
- fw = io.open(database_name+'_'+table_name+'.txt','a') 
- priv_str = '' 
- priv_line = '' 
- goal_flag = 0 
- for row in f: 
- # 处理首行 
- if row[0:3] == '###' and priv_str != '###': 
- if database_name in row and table_name in row: 
- goal_flag = 1 
- fw.write(priv_line) 
- fw.write(row) 
- # 处理末行 
- if row[0:3] != '###' and priv_str == '###': 
- goal_flag = 0 
- # 处理目标操作 
- if row[0:3] == '###' and priv_str == '###' and goal_flag == 1: 
- fw.write(row) 
- priv_str = row[0:3] 
- priv_line = row 
- f.close() 
- fw.close() 
- if __name__ == '__main__': 
- # python2.7 pickupbinlog.py mysql-bin.001051 dbname tablename 
- # python3 pickupbinlog.py mysql-bin.001051 dbname tablename 
- format_binlog() 
- pickupbinlog() 
看完了这篇文章,相信你对“如何提取MySQL binlog中指定表的操作记录”有了一定的了解,如果想了解更多相关知识,欢迎关注创新互联行业资讯频道,感谢各位的阅读!
文章标题:如何提取MySQLbinlog中指定表的操作记录
当前URL:http://www.scyingshan.cn/article/jisece.html

 建站
建站
 咨询
咨询 售后
售后
 建站咨询
建站咨询 
 