#!/usr/local/bin/python3.5
###Destription: 实时读取log信息
###Author:      Danny Deng
###Datetime:    2016-11-17
import re,time,subprocess,os,linecache
###############定义log文件
file_name = "/var/log/mongodb/mongodb.log"
file_number = "/usr/local/zabbix_agent/number.txt"
j = int(0)
seek = int(0)
###############判断文件是否存在---判断number是否存在---判断number size 与 filesize
###############定义一个函数，遍历文件
def readline():
###############if判断 seek是否大于0，大于则赋值，否则初始为0while True:
###############定义文件，根据seek值进行每行读取，每次tell赋值给seekwith open(file_name,'r') as f:global seek#seek = seekf.seek(seek)data = f.readline()if  data:seek = f.tell()yield dataelse:
###############Python变量转换为shell变量global file_numberos.environ['seek'] = str(seek)os.environ['file_number'] = str(file_number)
###############记录上一次执行后的seek值，下次执行直接读取os.system('echo $seek > $file_number')os.system('chown zabbix.zabbix $file_number')return
###############定义函数，find特定字符串从每行数据中
def func_for():j = int(0)for i in readline():f_find = re.findall(r"error", i,flags=re.IGNORECASE)if "error" in f_find:j += 1
###############没有输出0，有值输出出现error匹配到的次数值try:print(j)except NameError:print(int("0"))
###############判断文件是否存在
if os.path.isfile(file_name):
###############判断存储seek的文件是否存在if os.path.isfile(file_number):
###############存在时，读取其seek值seek_number = int(linecache.getline(file_number, 1))
###############如果有值判断seek值与现在文件大小值，大于说明log文件已重新生成，重置seek值为0if os.path.getsize(file_name) >= seek_number and seek_number > 0:seek = seek_numberfunc_for()else:seek = int(0)func_for()
###############如果存储seek值的文件不存在，新建并出示seek值为0else: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()