Python脚本实时处理log文件的方法_Python

这个Python脚本是用来对实时文件的内容监控，比如 Error 或者 time out 字段都可以进行自定义；算是我的第一个真正的Python脚本，自己感觉还是比较臃肿，不过打算放到blog上记录一下（还是初学者，大神们勿喷哈），真心希望博友们能够再指点一下(现在记录每次的文件大小值是输出到了一个文件中，并且里面还嵌套了有shell命令，这些我认为都是可以优化掉的吧，只是现在我还不知道怎么做）；告警是基于zabbix，自定义的模板是120s执行一次

				?

									#!/usr/local/bin/python3.5

									###Destription: 实时读取log信息

									###Author: Danny Deng

									###Datetime: 2016-11-17

									import re,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)

									##判断过程：文件是否存在---判断存储日志大小的文件是否存在---判断number size 与 filesize的大小

									###定义函数按行读取文件内容

									def readline():

									####if判断 seek是否大于0，大于则赋值，否则初始为0

									while True:

									######定义文件，根据seek值进行每行读取，每次tell赋值给seek

									with open(file_name,'r') as f:

									global seek

									#seek = seek

									f.seek(seek)

									data = f.readline()

									if data:

									seek = f.tell()

									yield data

									else:

									######Python变量转换为shell变量

									global file_number

									os.environ['seek'] = str(seek)

									os.environ['file_number'] = str(file_number)

									os.system('echo $seek > $file_number')

									os.system('chown zabbix.zabbix $file_number')

									return

									def func_for():

									j = int(0)

									for i in readline():

									f_find = re.findall(r"check time out", i,flags=re.IGNORECASE)

									if "check time out" in f_find:

									j += 1

									#####没有输出0，有值输出出现error匹配到的次数值

									try:

									print(j)

									except NameError:

									print(int("0"))

									###判断日志文件是否存在

									if os.path.isfile(file_name):

									###判断存储文件内容大小的文件是否存在

									if os.path.isfile(file_number):

									####存在则读取文件size大小，赋值给seek_number

									seek_number = int(linecache.getline(file_number, 1))

									####然后继续判断存储的文件大小与现在文件大小(确定文件是否是重新生成的)

									if os.path.getsize(file_name) >= seek_number and seek_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('echo 0 > $file_number')

									os.system('chown zabbix.zabbix $file_number')

									func_for()

									else:

									print("Error")

									quit()

以上所述是小编给大家介绍的Python脚本实时处理log文件脚本，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！

原文链接：http://www.cnblogs.com/tony-d/archive/2016/11/21/6084119.html

Python脚本实时处理log文件的方法

相关文章

热门资讯