平武建站

如何提取MySQLbinlog中指定表的操作记录

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

创新互联坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站制作、成都网站建设、外贸营销网站建设、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的威远网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！

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

点击(此处)折叠或打开

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

  3. import sys

  4. import os

  5. import io

  7. binlogfile = sys.argv[1]

  8. database_name = sys.argv[2]

  9. table_name = sys.argv[3]

  11. def format_binlog():

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

  14. def pickupbinlog():

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

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

  17.     priv_str = ''

  18.     priv_line = ''

  19.     goal_flag = 0

  20.     for row in f:

  21.         # 处理首行

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

  23.             if database_name in row and table_name in row:

  24.                 goal_flag = 1

  25.                 fw.write(priv_line)

  26.                 fw.write(row)

  27.         # 处理末行

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

  29.             goal_flag = 0

  30.         # 处理目标操作

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

  32.             fw.write(row)

  33.         priv_str = row[0:3]

  34.         priv_line = row

  35.     f.close()

  36.     fw.close()

  38. if __name__ == '__main__':

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

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

  41.     format_binlog()

  42.     pickupbinlog()

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


当前文章：如何提取MySQLbinlog中指定表的操作记录
当前链接：http://pwwzsj.com/article/jisece.html

其他资讯