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