Python實現的查詢mysql資料庫並通過郵件傳送資訊功能
阿新 • • 發佈：2020-01-09
本文例項講述了Python實現的查詢mysql資料庫並通過郵件傳送資訊功能。分享給大家供大家參考，具體如下：
這裡使用Python查詢mysql資料庫，並通過郵件傳送宕機資訊。
Python程式碼如下：
#-*- coding: UTF-8 -*- #!/usr/bin/env python ''''' author:qlzhong Created on 2015-6-29 征途宕機日誌統計彙總 ''' import MySQLdb import time import datetime import smtplib from email.mime.text import MIMEText mailto_list=["[email protected]"] #mailto_list=["[email protected]"] mail_host="smtp.qq.com" #設定伺服器 mail_user="" #使用者名稱 mail_pass="" #口令 mail_postfix="" #發件箱的字尾 def send_mail(to_list,sub,content): me="hello"+"<"+mail_user+"@"+mail_postfix+">" msg = MIMEText(content,_subtype='plain',_charset='utf-8') msg['Subject'] = sub msg['From'] = me msg['To'] = ";".join(to_list) try: server = smtplib.SMTP() server.connect(mail_host) server.login(mail_user,mail_pass) server.sendmail(me,to_list,msg.as_string()) server.close() return True except Exception,e: print str(e) return False class MySQLHelper: #配置資料庫資訊並連線 def __init__(self,host="****",user="****",password="****",port=3306,charset="utf8"): self.host=host self.user=user self.password=password self.port=port self.charset=charset try: self.conn=MySQLdb.connect(host=self.host,user=self.user,passwd=self.password,port=self.port) self.conn.set_character_set(self.charset) self.cur=self.conn.cursor() print("==================connect success====================") except MySQLdb.Error as e: print("Mysql Error %d: %s" % (e.args[0],e.args[1])) #取出需要統計的資料庫名稱 def db_name(self): un_db_name = ['information_schema','cz','ecshop','edutone','gz','mysql','newparent','parent','performance_schema','test','xx','yyhd'] name = [] try: self.cur.execute('show databases') for row in self.cur.fetchall(): for i in row: if i not in un_db_name: name.append(i) return name except MySQLdb.Error as e: print("Mysql Error %d: %s" % (e.args[0],e.args[1])) #指定查詢的資料庫名稱 def selectDb(self,db): try: self.conn.select_db(db) except MySQLdb.Error as e: print("Mysql Error %d: %s" % (e.args[0],e.args[1])) #使用該語句來直接查詢昨天和今天的差異 def monion_today_yesddiff(self,today,yestoday): try: strresult = "" strsql = 'SELECT address,charversion,sum(today) as today,sum(yesterday) as yesterday ' strsql += 'FROM (SELECT address,"" as today,tmp as yesterday,charversion FROM ( SELECT count(*) As tmp,address,charversion From `' + yestoday strsql += '` WHERE charversion like \'1.0.0.3%\' GROUP BY address) As TEST WHERE tmp>=50 ' strsql += ' union all ' strsql += 'SELECT address,tmp as today,"" as yesterday,charversion FROM (SELECT count(*) As tmp,charversion From `' strsql += today strsql += '` WHERE charversion like \'1.0.0.3%\' GROUP BY address) As TEST WHERE tmp>=50 ) As Diff GROUP BY address,charversion' print(strsql + "\n") self.cur.execute(strsql) name_list = [tuple[0] for tuple in self.cur.description] strresult += str(name_list) + "\n" # for row in self.cur.fetchall(): # return row s = self.cur.fetchall() todaynum = 0 yestodaynum = 0 for col in s: strresult += str(col[0]) + " " + str(col[1]) + " " + str(col[2]) + " " + str(col[3]) + "\n" todaynum += int(col[2]) yestodaynum += int(col[3]) strresult += "今日宕機總數：" + str(todaynum) + " 昨日宕機總數：" + str(yestodaynum) + " 同昨日相比增加: " + str(todaynum - yestodaynum) + "\n" return strresult except MySQLdb.Error as e: print("Mysql Error:%s\n" %(e)) def close(self): self.cur.close() self.conn.close() todayrang = 0; yestodayrang = 0; #按照範圍查詢 def monion_rang_today_yesddiff(self,yestoday,num1,num2): try: strresult = "" strsql = 'SELECT sum(today) as today,sum(yesterday) as yesterday FROM (SELECT "" as today,tmp as yesterday FROM ( SELECT count(*) As tmp From `' + yestoday strsql += '` WHERE charversion like \'1.0.0.3%\' GROUP BY address) As TEST WHERE tmp<' + str(num2) + ' AND tmp>=' + str(num1) + ' union all ' strsql += 'SELECT tmp as today,"" as yesterday FROM (SELECT count(*) As tmp From `' + today + '` WHERE charversion like \'1.0.0.3%\' GROUP BY address) As TEST WHERE tmp<' + str(num2) + ' AND tmp>=' + str(num1) + ' ) As Diff' print(strsql + "\n") self.cur.execute(strsql) name_list = [tuple[0] for tuple in self.cur.description] #strresult += str(name_list) + "\n" # for row in self.cur.fetchall(): # return row s = self.cur.fetchall() todaynum = 0 yestodaynum = 0 for col in s: strresult += str(num1) + " <= tmp < " + str(num2) + " " + str(col[0]) + " " + str(col[1]) + "\n" self.todayrang += int(col[0]) self.yestodayrang += int(col[1]) return strresult except MySQLdb.Error as e: print("Mysql Error:%s\n" %(e)) def close(self): self.cur.close() self.conn.close() #宕機數地址50以下最多的版本 def monion_rang_today_diff(self,num): try: strresult = "" strsql = 'SELECT charversion,sum(today) as today FROM (SELECT tmp as today,charversion From `' + today strsql += '` WHERE charversion like \'1.0.0.3%\' GROUP BY address) As TEST WHERE tmp< ' + str(num) + ') As Diff GROUP BY charversion' print(strsql + "\n") self.cur.execute(strsql) name_list = [tuple[0] for tuple in self.cur.description] #strresult += str(name_list) + "\n" # for row in self.cur.fetchall(): # return row s = self.cur.fetchall() for col in s: strresult += str(col[0]) + " " + str(col[1]) + "\n" return strresult except MySQLdb.Error as e: print("Mysql Error:%s\n" %(e)) def close(self): self.cur.close() self.conn.close() if __name__ == '__main__': textbody="" textbody = textbody + "征途宕機日誌查詢彙總" + "\n" #時間 timenow = datetime.datetime.now() textbody = textbody + "時間：" + timenow.strftime('%Y-%m-%d %H:%M:%S') + "\n" #連線 ipadress="192.168.100.38" port=3306 dbHelper = MySQLHelper(ipadress,"gameerror","errorpasswd",port) textbody = textbody + "伺服器地址：" + ipadress + ":" + str(port) + "\n" dbHelper.selectDb("GAMEERROR") #操作 dbname = dbHelper.db_name() textbody = textbody + "資料庫：" + str(dbname[0]) + "\n" time1 = timenow + datetime.timedelta(days = -1) time2 = timenow + datetime.timedelta(days = -2) strtime1 = time1.strftime('%Y%m%d') tabletoday = "ErrorDump" + strtime1 strtime2 = time2.strftime('%Y%m%d') tableyestoday = "ErrorDump" + strtime2 textbody = textbody + "table name: today: " + tabletoday + " yestoday: " + tableyestoday + "\n" textbody = textbody + "\n昨天和今天的差異 宕機地址 版本號 今天宕機次數 昨天宕機次數" + "\n" textbody = textbody + str(dbHelper.monion_today_yesddiff(tabletoday,tableyestoday)) + "\n" textbody = textbody + "50以下地址(tmp代表某個宕機地址的個數) 今天 昨天:" + "\n" textbody = textbody + str(dbHelper.monion_rang_today_yesddiff(tabletoday,tableyestoday,30,50)) textbody = textbody + str(dbHelper.monion_rang_today_yesddiff(tabletoday,10,30)) textbody = textbody + str(dbHelper.monion_rang_today_yesddiff(tabletoday,10)) textbody = textbody + "50以上地址總和" + " 今天： " + str(dbHelper.todayrang) + " 昨天: " + str(dbHelper.yestodayrang) + " 今天比昨天增加: " + str(dbHelper.todayrang - dbHelper.yestodayrang) + "\n" num=50 textbody = textbody + "\n宕機數地址" + str(num) + "以下最多的版本 版本號 次數" + "\n" textbody = textbody + str(dbHelper.monion_rang_today_diff(tabletoday,num)) file_object = open('ztdumptip.txt') try: all_the_text = file_object.read() finally: file_object.close() textbody += all_the_text print(textbody) if send_mail(mailto_list,"征途客戶端宕機日誌統計",textbody): print "傳送成功" else: print "傳送失敗" dbHelper.close()
更多關於Python相關內容感興趣的讀者可檢視本站專題：《Python+MySQL資料庫程式設計入門教程》、《Python常見資料庫操作技巧彙總》、《Python數學運算技巧總結》、《Python資料結構與演算法教程》、《Python函式使用技巧總結》、《Python字串操作技巧彙總》、《Python入門與進階經典教程》及《Python檔案與目錄操作技巧彙總》
希望本文所述對大家Python程式設計有所幫助。