python数据库查询监控

#!/usr/bin/python2.7
# encoding: utf-8

#import MySQLdb as MySQLdb
import MySQLdb
import traceback
import time
import smtplib
from email.mime.text import MIMEText

def getCurrentDateTime():
now=int(time.time())
timeArray=time.localtime(now)
todayDate=time.strftime("%Y-%m-%d",timeArray)
todayTime=time.strftime("%H:%M:%S",timeArray)
todayDateTime=time.strftime("%Y-%m-%d %H:%M:%S",timeArray)
return todayDateTime

def sendMail(tomail,subject,body):
HOST="aaa.123.com"
SUBJECT=subject
TO=tomail
FROM="11@aa.com"
text=body

msg=MIMEText(text,"plain","utf-8")
msg['Subject'] = SUBJECT
msg['From'] = FROM
msg['To'] = ','.join(TO)

try:
server=smtplib.SMTP()
server.connect(HOST,"25")
server.starttls()
server.login("11@aa.com","bbbbbb")
server.sendmail(FROM,TO,msg.as_string())
server.quit()
print "邮件发送成功"
except Exception,e:
print "失败"+str(e)

def connRemoteMysql(*arg):

ip = arg[0]
user = arg[1]
passwd = arg[2]
port = arg[3]

try:
conn = MySQLdb.connect(host=ip,user=user,passwd=passwd,port=port,charset='utf8') #关键字参数
#cursor = conn.cursor(cursorclass=MySQLdb.cursors.DictCursor) #传递参数cursors.DictCursor返回字典结构
cursor = conn.cursor() #获取操作游标
conn.select_db('aaa') #得到当前指向数据库的指针
#sql1 = 'select * from aaa_user ;'
sql2 = 'select count(*) from bbb_user;'
cursor.execute(sql2) #执行命令方法
tuple1 = cursor.fetchall() #接收返回值方法
tuple2 = tuple1[0]
result = tuple2[0]
#print "当前注册用户数为：%s" % r #内置%格式化字符串，
#print "aaaa：{num}人。".format(num=result) #str.format()字符串处理函数
#conn.commit()
return result
except:
traceback.print_exc()
conn.rollback()
finally:
cursor.close()
conn.close()
if __name__ == "__main__":

ip = "192.168.11.1"
user = "aaa"
passwd = "bbbbb"
port = 3306
person = connRemoteMysql(ip,user,passwd,port)

tomail = ['11@qq.com']
body = "aaa：{}".format(person)
subject = "aaa-%s" % getCurrentDateTime()
sendMail(tomail, subject, body)