python分析postfix邮件日志的状态
公司需求：客服通过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\.-]+@(?:+\.)++')
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,e.args)
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：
页:
[1]