Mysql sql慢查詢監(jiān)控腳本代碼實(shí)例
1、修改my.cnf
#整體的效果,全局開(kāi)啟表和日志文件都寫,但是對(duì)于general_log只寫表,對(duì)于slow_query_log,表和日志文件都記錄。general_log=1#開(kāi)啟mysql執(zhí)行sql的日志 slow_query_log=1#開(kāi)啟mysql慢sql的日志#設(shè)置之后會(huì)影響general_log和slow_query_log,log_output=table,File#日志輸出會(huì)寫表,也會(huì)寫日志文件,為了便于程序去統(tǒng)計(jì),所以最好寫表#這里沒(méi)配置general_log_file,那么general_log就只會(huì)寫表了#在mysql5.1.29以上,設(shè)置以下即可打開(kāi)mysql將執(zhí)行的sql記錄在文件中#general_log_file=/log/general.log#5.1.29以以前為:#log=/var/lib/mysql/sql_row.loglong_query_time=1#設(shè)置mysql的慢查詢?yōu)槌^(guò)1s的查詢 slow_query_log_file=/log/slow.log
2、修改mysql的日志表(在mysql庫(kù)中)的格式
#默認(rèn)general_log是csv的格式,修改為MyISAM格式查詢效率會(huì)高很多
set global general_log = off;
alter table general_log engine = MyISAM;
set global general_log = on;
#默認(rèn)slow_query_log是csv的格式,修改為MyISAM格式查詢效率會(huì)高很多
set global slow_query_log = off;等于0效果一樣
alter table slow_log engine = MyISAM;
set global slow_query_log = on;等于1效果一樣
3、因?yàn)閙ysql的日志表:general_log和slow_query_log不允許修改,所以需要新建出一個(gè)便于刪除修改的表(這個(gè)日志表太大,需要定期清理n天前得數(shù)據(jù))
建立slow_log_dba的表
CREATE TABLE `slow_log_dba` ( `start_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, `user_host` mediumtext NOT NULL, `query_time` time NOT NULL, `lock_time` time NOT NULL, `rows_sent` int(11) NOT NULL, `rows_examined` int(11) NOT NULL, `db` varchar(512) NOT NULL, `last_insert_id` int(11) NOT NULL, `insert_id` int(11) NOT NULL, `server_id` int(10) unsigned NOT NULL, `sql_text` mediumtext NOT NULL) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT=’Slow log for dba’;
建立general_log_dba的表
CREATE TABLE `general_log_dba` ( `event_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, `user_host` mediumtext NOT NULL, `thread_id` int(11) NOT NULL, `server_id` int(10) unsigned NOT NULL, `command_type` varchar(64) NOT NULL, `argument` mediumtext NOT NULL, KEY `user_host` (`user_host`(200)), KEY `event_time` (`event_time`)) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT=’general log for dba op’;
4、因?yàn)槌绦蜃罱K使用的general_log_dba和slow_log_dba的表,所以需要定時(shí)的將general_log和slow_query_log的數(shù)據(jù)拷貝到general_log_dba和slow_log_dba之中
因?yàn)閳?bào)告是每天生成一次,所以這個(gè)動(dòng)作只要每天操作一次即可
#腳本是保存10天得數(shù)據(jù),每天將general_log和slow_query_log的數(shù)據(jù)拷貝到general_log_dba和slow_log_dba之中
#做定時(shí)任務(wù)每天執(zhí)行一次 mysqllogtable.sh
#!/bin/sh
NDaysAgo=$(date -d ’-10 days’ '+%F %H:%M:%S')
/usr/local/mysql/bin/mysql -uXXXX -p’xxxxxxxx’ -D’mysql’ -e 'insert general_log_dba select * from general_log;
truncate general_log;
delete from general_log_dba where event_time < '$NDaysAgo';
insert slow_log_dba select * from slow_log;
truncate slow_log;
delete from slow_log_dba where start_time < '$NDaysAgo''
5、python腳本寫統(tǒng)計(jì)每天sql操作和每天的mysql的慢查詢(腳本中有部分是可以抽象的方法,請(qǐng)自己酌情處理)
統(tǒng)計(jì)mysql每日?qǐng)?zhí)行記錄的腳本
# -*- coding: utf-8 -*-__author__ = ’river’import MySQLdb as mysqlimport refrom datetime import datetime, timedeltaimport smtplibfrom email.mime.text import MIMETextdef sendHtmlMail(mailcontent,myip): try: yestoday=(datetime.now()-timedelta(days=1)).strftime('%Y-%m-%d') sender = ’xxx@xxx.com’ receiver = [’xxx@xxx.com’] subject = myip+’ mysql operation report ’+yestoday smtpserver = ’smtp.exmail.xx.com’ username = ’xxx@xxx.com’ password = ’xxxxx’ msg = MIMEText(mailcontent,’html’,’utf-8’)#’你好’,’text’,’utf-8’ msg[’Subject’] = subject msg[’From’] = sender msg[’To’] = ’xxx@xxxxxxxx.com’ smtp = smtplib.SMTP() smtp.connect(smtpserver) smtp.login(username, password) smtp.sendmail(sender, receiver, msg.as_string()) smtp.quit() except Exception, e: print e,’send mail error’if __name__==’__main__’: result=None htmlfile=’mysqlLogMon.html’ myiplist=[’192.168.10.10’,’192.168.10.19’] yestoday=(datetime.now()-timedelta(days=1)).strftime('%Y-%m-%d 00:00:00') today=datetime.now().strftime('%Y-%m-%d 00:00:00') for myip in myiplist: sql='select user_host,argument from general_log_dba where event_time >=’%s’ and event_time <=’%s’' %(yestoday,today) try: dbcon = mysql.connect(host=myip, user=’xxxxx’, passwd=’xxxxx’, db=’mysql’, port=3306,charset=’utf8’) cur = dbcon.cursor() print 'step 1,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S') cur.execute(sql) result = cur.fetchall() cur.close() dbcon.close() except Exception, e: print e,’conn mysql error’ user_host_set=set() print 'step 2,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S') allhash={} if result: for user_host,argument in result:argument_delcom=re.compile(r’(/*(s|.)*?*/)’).sub('',argument).strip().replace(u'x00',’’).lower()if re.compile(r’^access.*’).match(argument_delcom) or re.compile(r’^.*@.*on.*’).match(argument_delcom) or re.compile(r’^grant.*’).match(argument_delcom): tmpargument=argument_delcom.strip()else: tmpargument=argument_delcom.split(’ ’)[0].strip() if len(tmpargument)>30: #有些sql是u’selectntttttcount(m.enquirymainid)’,可以使用print repr(tmpargument) tmpargument=argument_delcom.split(’n’)[0].strip()#如果全是注釋,那么就不統(tǒng)計(jì)這條目了if not tmpargument or tmpargument.strip()==’’ or tmpargument.strip()==’ ’: continueif allhash.has_key(user_host): allhash[user_host][tmpargument]=allhash[user_host].get(tmpargument,0)+1else: allhash[user_host]={tmpargument:1} print 'step 3,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S') headhtml=’’’ ’’’ print 'step 4,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S') with open(htmlfile,’w’) as htmlfileobj:htmlfileobj.write(headhtml)htmlfileobj.flush() print 'step 5,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S') with open(htmlfile,’a’) as htmlfileobj:for hostkey in allhash.keys(): listtmp=sorted(allhash[hostkey].iteritems(),key=lambda labkey:labkey[1],reverse=True) rowspan=len(allhash[hostkey]) #htmlfileobj.write() tmpline=’’ %(rowspan,hostkey.encode(’utf-8’)) htmlfileobj.write(tmpline) countn=0 for runsql,count in listtmp: if countn==0: tmpline=’’ %(runsql.encode(’utf-8’),count) else: tmpline=’’ %(runsql.encode(’utf-8’),count) countn+=1 htmlfileobj.write(tmpline)tmpline=’’’用戶 執(zhí)行sql 執(zhí)行次數(shù)%s %s %s%s %s’’’htmlfileobj.write(tmpline) with open(htmlfile,’r’) as htmlfileobj:mailcontent=htmlfileobj.read() sendHtmlMail(mailcontent,myip) else: print ’sql result is None,exit ing’ print 'step 6,'+myip+’,’+datetime.now().strftime('%Y-%m-%d %H:%M:%S')
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. MySQL GRANT用戶授權(quán)的實(shí)現(xiàn)2. Oracle的約束介紹與約束維護(hù)3. Mysql命令行連接遠(yuǎn)程/本地?cái)?shù)據(jù)庫(kù)詳解4. MySQL 普通索引和唯一索引的區(qū)別詳解5. Oracle存儲(chǔ)過(guò)程的幾種調(diào)用方式圖文詳解6. mysql中使用date_add()函數(shù)講解7. SQL Server中T-SQL標(biāo)識(shí)符介紹與無(wú)排序生成序號(hào)的方法8. SQL語(yǔ)句如何實(shí)現(xiàn)超簡(jiǎn)單的多表查詢9. 分析DB2活動(dòng)日志滿的原因及解決DB2日志滿方法與避免方案10. MySQL函數(shù)CONCAT、CONCAT_WS、GROUP_CONCAT用法詳解
