想要獲取每天數據庫每張表的DML的次數，統計熱度表，可以使用該腳本
# coding:utf-8
# 解析binlog，統計熱度表，表的DML個數
import sys
import os
# mysqlbinlog解析binlog日志
def binlog_output():
binlog_file = sys.argv[1]
file_num = binlog_file.split('.')[1]
binlog_log = 'binlog_%s.log' % file_num
os.system('/usr/local/mysql5637/mysql/bin/mysqlbinlog -v --base64-output=decode-rows %s > %s' %(binlog_file, binlog_log))
return binlog_log
# 對
def binlog_parse(binlog_log):
delete_count = 0
update_count = 0
insert_count = 0
update_li = []
insert_li = []
delete_li = []
stop_time_li = []
binlog_f = open(binlog_log, 'r',encoding='utf-8')
for line in binlog_f.readlines():
if line.startswith('### INSERT INTO'):
insert_count += 1
insert_li.append(line[16:].replace('`', '').strip())
if line.startswith('### UPDATE'):
update_count += 1
update_li.append(line[11:].replace('`', '').strip())
if line.startswith('### DELETE FROM'):
delete_count += 1
delete_li.append(line[16:].replace('`','').strip())
if 'Start: binlog' in line:
start_time = line.split('server')[0].replace('#', '')
if 'end_log_pos' in line:
stop_time_li.append(line)
binlog_f.close()
stop_time = stop_time_li[-1].split('server')[0].replace('#', '')
start_time = '20' + start_time[:2] + '-' + start_time[2:4] + '-' + start_time[4:]
stop_time = '20' + stop_time[:2] + '-' + stop_time[2:4] + '-' + stop_time[4:]
return delete_count,update_count,insert_count,update_li,insert_li,delete_li,start_time,stop_time
# 對庫和表進統計排序
def DbTableCount(arr):
result = {}
for i in set(arr):
result[i] = arr.count(i)
sort_li = sorted(result.items(), key=lambda x: x[1], reverse=True)
return sort_li
if __name__ == '__main__':
binlog_log = binlog_output()
delete_count, update_count, insert_count, update_li, insert_li, delete_li, start_time,stop_time= binlog_parse(binlog_log)
sort_update_li = DbTableCount(delete_li)
sort_inser_li = DbTableCount(insert_li)
sort_delete_li = DbTableCount(update_li)
# 刪除解析日志
os.system('rm -f %s' % binlog_log)
# 收集時間
print('開始時間: ;', start_time)
print('結束時間: ;', stop_time)
# 統計DML總次數
print('\nDML總次數: ', insert_count+update_count+delete_count)
# 統計DML次數
print(' Insert總次數: ', insert_count)
print(' Delete總次數: ', delete_count)
print(' Update總次數: ', update_count)
# Insert統計
print('\nInsert 統計: ')
for i in sort_inser_li:
print(' DB.Table:', i[0], ', Count:', i[1])
# Delete統計
print('\nDelete 統計: ')
for i in sort_delete_li:
print(' DB.Table:', i[0], ', Count:', i[1])
# Update統計
print('\nUpdate 統計: ')
for i in sort_update_li:
print(' DB.Table:', i[0], ', Count:', i[1])
