python 实现简单的SYSLOG服务器，并写入MYSQL数据库代码,Python代码库,德仔网

代码语言

代码分类

【Python】 python 实现简单的SYSLOG服务器，并写入MYSQL数据库

作者:foxhackd / 发布于2011/1/10/ 2321

依赖myssqldb模块，适用于windows平台。此代码为初学python练手代码

import os,socket,sys,time,string
import MySQLdb
bufsize=1500
port=514</div>
<div>syslog_serverty={ 0:"emergency",
 1:"alert",
 2:"critical",
 3:"error",
 4:"warning",
 5:"notice",
 6:"info",
 7:"debug"
 }
syslog_facility={ 0:"kernel",
 1:"user",
 2:"mail",
 3:"daemaon",
 4:"auth",
 5:"syslog",
 6:"lpr",
 7:"news",
 8:"uucp",
 9:"cron",
 10:"authpriv",
 11:"ftp",
 12:"ntp",
 13:"security",
 14:"console",
 15:"cron",
 16:"local 0",
 17:"local 1",
 18:"local 2",
 19:"local 3",
 20:"local 4",
 21:"local 5",
 22:"local 6",
 23:"local 7"
 }
<div>
try:
 sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
 sock.bind(("0.0.0.0",port))
except:
 print("error bind")
 sys.exit(1)
sql_em="insert into emergency values(%s,%s,%s,%s,%s,%s)"
sql_al="insert into alert values(%s,%s,%s,%s,%s,%s)"
sql_cr="insert into critical values(%s,%s,%s,%s,%s,%s)"
sql_er="insert into error values(%s,%s,%s,%s,%s,%s)"
sql_wa="insert into warning values(%s,%s,%s,%s,%s,%s)"
conn=MySQLdb.connect(host="127.0.0.1",db="syslog",port=18888,user="root",passwd="cinda")
curs=conn.cursor()
#f=file("syslog.txt","w")
print ("----------------syslog is start----------------\n")
try:
 while 1:
 try:
 data,addr=sock.recvfrom(bufsize)
 #print data,addr
 syslog=str(data)
 n=syslog.find('>')
 serverty=string.atoi(syslog[1:n])&0x0007
 facility=(string.atoi(syslog[1:n])&0x03f8)>>3
 syslog_msg=syslog[26:]
 dev_name=syslog_msg[:syslog_msg.find(' ')]
 dev_msg=syslog_msg[syslog_msg.find(' '):]
 param=(time.strftime("%Y-%m-%d %H:%M:%S",time.localtime()),dev_name,addr[0],syslog_facility[facility],syslog_serverty[serverty],dev_msg)
 
 if serverty==0:
 curs.execute(sql_em,param)
 print syslog_msg
 elif serverty==1:
 curs.execute(sql_al,param)
 print syslog_msg
 elif serverty==2:
 curs.execute(sql_cr,param)
 print syslog_msg
 elif serverty==3:
 curs.execute(sql_er,param)
 print syslog_msg
 elif serverty==4:
 curs.execute(sql_wa,param)
 print syslog_msg
 
 conn.commit()
 
 #print dev_msg,time.strftime("%Y-%m-%d %H:%M:%S",time.localtime())
 #print syslog_serverty[serverty],syslog_facility[facility],syslog[26:]
 #f.writelines(syslog_serverty[serverty]+" "+syslog_facility[facility]+" "+syslog[26:]+'\n')
 except socket.error:
 pass
except KeyboardInterrupt:
 curs.close()
 conn.close()
 print ("------------------syslogd stop-------------\n")
 print "good bye"
 sys.exit()
#f.close</div>

试试其它关键字

　SYSLOG　

同语言下

可能有用的

foxhackd贡献的其它代码(1)

.python 实现简单的SYSLOG服务器，并写入MYSQL数据库