python分析postfix邮件日志的状态

sky

公司需求：客服通过WEB想查询 某一时间他发送的邮件的 状态，如果是拒绝是什么原因导致的。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115

#!/usr/bin/env python import re import threading import MySQLdb import datetime,time ########################################################################################### def Gainid(log):     #mail id re     mailid = re.compile(r'\w{11}\:')     list_id = []     for line in log:         m  = mailid.search(line)         if m is not None:             list_id.append(m.group().strip(':'))         else:             continue     return list(set(list_id)) def HandleLog(log,mailid):     mdict = {}     tomail = ''     fmail = ''     for line in log:         m = re.search(mailid,line)         if m is not None:             mailre = re.compile(r'[^\._-][\w\.-]+@(?:[A-Za-z0-9]+\.)+[A-Za-z]+')             timere = re.compile(r'^\w+\s+\d+\s\d{2}\:\d{2}:\d{2}')             nt = timere.search(line)             mtime = nt.group()             n = mailre.search(line)             if n is not None:                 f = re.search(r'from\=',line)                 t = re.search(r'to\=',line)                 if f is not None:                     fmail = n.group().strip('<')                 if t is not None:                     tmail = n.group().strip('<')                     statre = re.search(r'\(250',line)                     if statre is not None:                         status = "OK"                     if statre is None:                         statre = re.search(r'Sender address rejected',line)                         if statre is not None:                             status = "User unknown"                         if statre is None:                             statre = re.search(r'Recipient address rejected',line)                             if statre is not None:                                       status = "User unknown"                                if statre is None:                                           status = "other"                     print ("id: %s date :%s  |frdr: %s |  todr: %s | status: %s" % (mailid,mtime ,fmail,tmail,status))                     ttime = fromttime(mtime)                        sql = "insert into mailtest values('%s','%s','%s','%s','%s')" % (mailid,ttime ,fmail,tmail,status)                                 insertmail(sql) #                    if tomail: #                        tomail = tomail+"(%s|%s)" % (tmail,status) #                    else: #                        tomail = "(%s|%s)" % (tmail,status)         else:             continue #    mdict['time'] = mtime #    if fmail: #        mdict['from'] = fmail #    else: #        mdict['from'] = '' #    mdict['to'] = tomail #    mdict['id'] = mailid #    #    print mdict def fromttime(mtime):     today = datetime.date.today()           yer   =     today.strftime("%Y")           mtime =  yer + mtime     ntime =  time.strptime(mtime,"%Y%b  %d %H:%M:%S")     ttime =  time.strftime('%Y-%m-%d %H:%M:%S',ntime)     return ttime def insertmail(sql):     try:         conn=MySQLdb.connect(host='localhost',user='root',passwd='####',port=3306,db='dbname')         cur = conn.cursor()     cur.execute(sql)         cur.close()     conn.commit()         conn.close()     except MySQLdb.Error,e:         print "Mysql Error %d: %s" % (e.args[0],e.args[1])                     def main(logfile):     #open file     f = open(logfile,'r')     log = f.readlines()     f.close()     #mail id     mailid = Gainid(log)     #HandleLog     threads = {}     for i in range(len(mailid)):         HandleLog(log,mailid)         #    HandleLog(log,'850DA916966')         if __name__ == "__main__":     today = datetime.date.today()     oneday = datetime.timedelta(days=1)     yesterday = today - oneday     tommorrow = today + oneday     #print yesterday     zhi = yesterday.strftime("%Y%m%d")     logfile = "mail.log.%s" % zhi     main(logfile)

WEB 展现通过apahce+php：