如何提取MySQL binlog中指定表的操作記錄

小編給大家分享一下如何提取MySQL  binlog中指定表的操作記錄，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

一段簡單的Python腳本，需要本地裝了合適版本的mysqlbinlog工具。
支持Python 2.7+

點(diǎn)擊(此處)折疊或打開

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

2. 
   

3. import sys
   

4. import os
   

5. import io
   

6. 
   

7. binlogfile = sys.argv[1]
   

8. database_name = sys.argv[2]
   

9. table_name = sys.argv[3]
   

10. 
    

11. def format_binlog():
    

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

13. 
    

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.         # 處理目標(biāo)操作
    

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()
    

37. 
    

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中指定表的操作記錄”有了一定的了解，如果想了解更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！