如何提取MySQLbinlog中指定表的操作记录-创新互联-成都创新互联网站建设

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

如何提取MySQLbinlog中指定表的操作记录-创新互联

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

创新互联长期为成百上千家客户提供的网站建设服务,团队从业经验10年,关注不同地域、不同群体,并针对不同对象提供差异化的产品和服务;打造开放共赢平台,与合作伙伴共同营造健康的互联网生态环境。为上林企业提供专业的做网站、网站建设上林网站改版等技术服务。拥有十多年丰富建站经验和众多成功案例,为您定制开发。

一段简单的Python脚本,需要本地装了合适版本的mysqlbinlog工具。
支持Python 2.7+

点击(此处)折叠或打开

  1. #_*_ coding:utf-8 _*_

  2. import sys

  3. import os

  4. import io

  5. binlogfile = sys.argv[1]

  6. database_name = sys.argv[2]

  7. table_name = sys.argv[3]

  8. def format_binlog():

  9.     os.system('mysqlbinlog --base64-output=decode-rows -v '+binlogfile+'>'+binlogfile+'.txt')

  10. def pickupbinlog():

  11.     f = io.open(binlogfile+'.txt','r')

  12.     fw = io.open(database_name+'_'+table_name+'.txt','a')

  13.     priv_str = ''

  14.     priv_line = ''

  15.     goal_flag = 0

  16.     for row in f:

  17.         # 处理首行

  18.         if row[0:3] == '###' and priv_str != '###':

  19.             if database_name in row and table_name in row:

  20.                 goal_flag = 1

  21.                 fw.write(priv_line)

  22.                 fw.write(row)

  23.         # 处理末行

  24.         if row[0:3] != '###' and priv_str == '###':

  25.             goal_flag = 0

  26.         # 处理目标操作

  27.         if row[0:3] == '###' and priv_str == '###' and goal_flag == 1:

  28.             fw.write(row)

  29.         priv_str = row[0:3]

  30.         priv_line = row

  31.     f.close()

  32.     fw.close()

  33. if __name__ == '__main__':

  34.     # python2.7 pickupbinlog.py mysql-bin.001051 dbname tablename

  35.     # python3 pickupbinlog.py mysql-bin.001051 dbname tablename

  36.     format_binlog()

  37.     pickupbinlog()

看完了这篇文章,相信你对“如何提取MySQL  binlog中指定表的操作记录”有了一定的了解,如果想了解更多相关知识,欢迎关注创新互联-成都网站建设公司行业资讯频道,感谢各位的阅读!


本文标题:如何提取MySQLbinlog中指定表的操作记录-创新互联
转载来于:http://kswsj.cn/article/ceojgd.html

其他资讯