Python实现的查询mysql数据库并通过邮件发送信息功能

本文实例讲述了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=["mail@mail.com"]
#mailto_list=["zhongqilong@ztgame.com"]
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, address, 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, today, 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, today, num):
    try:
      strresult = ""
      strsql = 'SELECT charversion, sum(today) as today FROM (SELECT tmp as today, "" as yesterday, charversion FROM (SELECT count(*) As tmp, 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, tableyestoday, 10, 30))
  textbody = textbody + str(dbHelper.monion_rang_today_yesddiff(tabletoday, tableyestoday, 0, 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程序设计有所帮助。

时间: 2018-05-17

python3.4实现邮件发送功能

本文实例为大家分享了python实现邮件发送功能的具体代码,供大家参考,具体内容如下 import smtplib import os from email.mime.text import MIMEText from email.mime.multipart import MIMEMultipart from email import encoders user = '*******@qq.com' pwd = '*******' to = ['******@139.com', '******

Python实现定时备份mysql数据库并把备份数据库邮件发送

一.先来看备份mysql数据库的命令 mysqldump -u root --password=root --database abcDataBase > c:/abc_backup.sql 二.写Python程序 BackupsDB.py #!/usr/bin/python # -*- coding: UTF-8 -*- ''''' zhouzhongqing 备份数据库 ''' import os import time import sched import smtplib from em

python2.7实现邮件发送功能

要想实现一个能够发送带有文本.图片.附件的python程序,首先要熟悉两大模块: email以及smtplib 然后对于MIME(邮件扩展)要有一定认知,因为有了扩展才能发送附件以及图片这些媒体或者非文本信息 最后一个比较细节的方法就是MIMEMultipart,要理解其用法以及对应参数所实现的功能区别 发送邮件三部曲: 创建协议对象 连接邮件服务器 登陆并发送邮件 from email.header import Header from email.mime.base import MIMEB

python使用smtplib模块通过gmail实现邮件发送的方法

本文实例讲述了python使用smtplib模块通过gmail实现邮件发送的方法.分享给大家供大家参考.具体实现方法如下: import smtplib from email.MIMEMultipart import MIMEMultipart from email.MIMEText import MIMEText fromaddr = 'fromaddr@gmail.com' toaddr = 'toaddr@gmail.com' text = 'test email message sent

python实现QQ邮箱/163邮箱的邮件发送

QQ邮箱/163邮箱的邮件发送:py文件发送邮件内容相当于一个第三方的客户端,借助于QQ/163邮箱服务器来发送的邮件. 主要配置: 导入模块--import    smtplib 邮箱SMTP服务器的主机地址,HOST--将来使用这个服务器收发邮件. 配置服务器端口,PORT --默认的邮件端口是25(QQ邮箱是:465) 指定发件人和收件人,(FROM.TO)--发件人只有一个,收件人有多个,收件人格式:'邮箱1,邮箱2,...' 邮件标题(SUBJECT) 邮件内容(CONTENT) 邮箱

python实现SMTP邮件发送功能

一直想着给框架添加邮件发送功能.所以整理下python下邮件发送功能 首先python是支持邮件的发送.内置smtp库.支持发送纯文本.HTML及添加附件的邮件.之后是邮箱.像163.qq.新浪等邮箱默认关闭SMTP服务,需要我们手动打开,打开后通过发件人邮箱.授权密码 通过发件人的SMTP服务发送 代码如下: #!/usr/bin/env python # -*- coding: utf_8 -*- from email.mime.text import MIMEText from email

python实现自动发送邮件发送多人、群发、多附件的示例

1.最近公司实现部分数据统计.分析的报表进行每天定时发送到相关人员的邮箱之中的配置代码被人为删除了,需要重新恢复该功能,由于原先是在linux上使用shell配置发送,实在是太繁琐,所以准备使用python来实现该功能,不过发现网上各种文档都是未经过整理,代码写的很不友善,比如发送多人的只能发送前一个邮箱,附件写死不灵活等等,故特写一遍比较记录. 主要会遇到的几个问题: 1.smtplib.SMTPAuthenticationError: (550, b'User has no permissi

python实现12306抢票及自动邮件发送提醒付款功能

#写在前面,这个程序我已经弄出来了,但是因为黄牛泛滥以及懒人太多,整个程序的代码就不贴出来了,这里纯粹就是技术交流. 只做技术交流..... 嗯,程序结束后,自己还是得手动付款. 废话不多说,下面就直接开始技术主要部分阐述. 先讲理论部分:首先我们需要代码实现一个浏览器功能,那么模块基本上可以确定urllib.parse.urllib.request,这两个包都是和网址有关的模块,那么咱们去登录一个网址,特别是有验证码这些的网址,我们登录进去是不是就行了?答案是对的,但是我们用代码实现的话,这个

python邮件发送smtplib使用详解

本文实例为大家分享了python邮件发送smtplib使用具体代码,供大家参考,具体内容如下 文件形式的邮件 #!/usr/bin/env python3 #coding: utf-8 import smtplib from email.mime.text import MIMEText from email.header import Header sender = '***' receiver = '***' subject = 'python email test' smtpserver

利用python实现简单的邮件发送客户端示例

脚本过于简单,供学习和参考.主要了解一下smtplib库的使用和超时机制的实现.使用signal.alarm实现超时机制. #!/usr/bin/env python # -*- coding: utf-8 -*- import time import sys import logging import smtplib import socket import signal import ConfigParser from datetime import datetime from email

python模块smtplib实现纯文本邮件发送功能

今天学到了如何使用Python的smtplib库发送邮件,中间也是遇到了各种各样的错误和困难,还好都一一的解决了.下面来谈一谈我的这段经历. 配置你的邮箱 为什么要配置邮箱呢?具体要配置什么呢? 因为我们申请的一些免费邮箱都是默认不开启smtp/pop协议的. SMTP是发邮件使用到的计算机网络中应用层协议中的一个:而POP则是收邮件时使用到的计算机网络中的应用层协议的其中一个.这都是理论性的知识了,上过计算机网络这门课的想必都知道,就不多说了. 配置就是要开启这项服务.否则我们就不能实现用Py

python定时利用QQ邮件发送天气预报的实例

大致介绍 好久没有写博客了,正好今天有时间把前几天写的利用python定时发送QQ邮件记录一下 1.首先利用request库去请求数据,天气预报使用的是和风天气的API(www.heweather.com/douments/api/s6/weather-forecast) 2.利用python的jinja2模块写一个html模板,用于展示数据 3.python的email构建邮件,smtplib发送邮件 4.最后使用crontab定时执行python脚本 涉及的具体知识可以去看文档,本文主要就是

C#实现的自定义邮件发送类完整实例(支持多人多附件)

本文实例讲述了C#实现的自定义邮件发送类.分享给大家供大家参考,具体如下: using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Mail; using System.Net.Mime; namespace ConsoleApplication1 { /// <summary> /// 发送邮件类 的摘要说明 /// </summary&g

JavaWeb实现邮件发送接收功能实例解析

一.邮件开发涉及到的一些基本概念 1.1.邮件服务器和电子邮箱 要在Internet上提供电子邮件功能,必须有专门的电子邮件服务器.例如现在Internet很多提供邮件服务的厂商:sina.sohu.163等等他们都有自己的邮件服务器. 这些邮件服务器类似于现实生活中的邮局,它主要负责接收用户投递过来的邮件,并把邮件投递到邮件接收者的电子邮箱中. 电子邮箱(E-Mail地址)的获得需要在邮件服务器上进行申请,确切地说,电子邮箱其实就是用户在邮件服务器上申请的一个账户,用户在邮件服务器上申请了一个

ThinkPHP3.2.3框架邮件发送功能图文实例详解

本文实例讲述了ThinkPHP3.2.3框架邮件发送功能.分享给大家供大家参考,具体如下: 背景 web 开发过程中,经常会用到邮件的发送功能,比如接收消费账单的提醒.亚马逊图书推荐的推送,或者网站不正常操作报警的邮件提示等. 下面是一个在ThinkPHP 3.2.3 框架下集成 PHPMailer 使用的邮件发送功能实现过程,仅供参考,谢谢... 一.前期准备 1).首先对 STMP 的知识稍作了解 STMP 简介 <百度百科> 2).开启邮箱 STMP 服务 以 163.com 邮箱为例,

Python定时发送天气预报邮件代码实例

这篇文章主要介绍了Python定时发送天气预报邮件代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 用python爬虫爬到的天气预报,使用smtplib和email模块可以发送到邮箱,使用schedule模块可以定时发送.以下是代码- #导入模块 import requests from bs4 import BeautifulSoup import smtplib from email.mime.text import MIMEText

基于Python实现定时自动给微信好友发送天气预报

效果图 from wxpyimport * import requests from datetimeimport datetime import time from apscheduler.schedulers.blockingimport BlockingScheduler#定时框架 bot = Bot(cache_path=True) tuling = Tuling(api_key=你的api')#机器人api def send_weather(location): #准备url地址 pa

Python实现发送QQ邮件的封装

本文实例为大家分享了Python实现发送QQ邮件的封装代码,供大家参考,具体内容如下 封装code import smtplib from email.mime.image import MIMEImage from email.mime.multipart import MIMEMultipart from email.mime.text import MIMEText from email.header import Header # type=plain 文本格式 默认 # type=ht

详解用python自制微信机器人,定时发送天气预报

0 引言 前段时间找到了一个免费的天气预报API,费了好段时间把这个API解析并组装成自己想用的格式了,就想着如何实现每天发送天气信息给自己.最近无意中发现了wxpy库,用它来做再合适不过了.以下是wxpy库的简介: wxpy基于itchat,使用了 Web 微信的通讯协议,通过大量接口优化提升了模块的易用性,并进行丰富的功能扩展.实现了微信登录.收发消息.搜索好友.数据统计.微信公众号.微信好友.微信群基本信息获取等功能. 废话不多说,代码写起来. 1 环境 操作系统:Windows / Li