Python脚本实时处理log文件的方法
这个Python脚本是用来对实时文件的内容监控,比如Error或者timeout字段都可以进行自定义;算是我的第一个真正的Python脚本,自己感觉还是比较臃肿,不过打算放到blog上记录一下(还是初学者,大神们勿喷哈),真心希望博友们能够再指点一下(现在记录每次的文件大小值是输出到了一个文件中,并且里面还嵌套了有shell命令,这些我认为都是可以优化掉的吧,只是现在我还不知道怎么做);告警是基于zabbix,自定义的模板是120s执行一次
#!/usr/local/bin/python3.5
###Destription:实时读取log信息
###Author:DannyDeng
###Datetime:2016-11-17
importre,time,subprocess,os,linecache
#####定义log文件
file_name="/usr/local/nginx/logs/error.log"
file_number="/usr/local/zabbix_agent/number.txt"
j=int(0)
seek=int(0)
##判断过程:文件是否存在---判断存储日志大小的文件是否存在---判断numbersize与filesize的大小
###定义函数按行读取文件内容
defreadline():
####if判断seek是否大于0,大于则赋值,否则初始为0
whileTrue:
######定义文件,根据seek值进行每行读取,每次tell赋值给seek
withopen(file_name,'r')asf:
globalseek
#seek=seek
f.seek(seek)
data=f.readline()
ifdata:
seek=f.tell()
yielddata
else:
######Python变量转换为shell变量
globalfile_number
os.environ['seek']=str(seek)
os.environ['file_number']=str(file_number)
os.system('echo$seek>$file_number')
os.system('chownzabbix.zabbix$file_number')
return
deffunc_for():
j=int(0)
foriinreadline():
f_find=re.findall(r"checktimeout",i,flags=re.IGNORECASE)
if"checktimeout"inf_find:
j+=1
#####没有输出0,有值输出出现error匹配到的次数值
try:
print(j)
exceptNameError:
print(int("0"))
###判断日志文件是否存在
ifos.path.isfile(file_name):
###判断存储文件内容大小的文件是否存在
ifos.path.isfile(file_number):
####存在则读取文件size大小,赋值给seek_number
seek_number=int(linecache.getline(file_number,1))
####然后继续判断存储的文件大小与现在文件大小(确定文件是否是重新生成的)
ifos.path.getsize(file_name)>=seek_numberandseek_number>0:
seek=seek_number
func_for()
###若为新文件则,seek赋值为0
else:
#open(arg1,"a+").write("0")
#seek=int(linecache.getline(file_number,1))
seek=int(0)
func_for()
####file_number不存在则新建,并赋值seek变量为0
else:
#open(file_number,"a+").write("0")
#seek=int(linecache.getline(file_number,1))
os.environ['file_number']=str(file_number)
os.system('echo0>$file_number')
os.system('chownzabbix.zabbix$file_number')
func_for()
else:
print("Error")
quit()
以上所述是小编给大家介绍的Python脚本实时处理log文件脚本,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持!