本文实例为大家分享了python定时提取实时日志的具体代码,供大家参考,具体内容如下
这是一个定时读取实时日志文件的程序。目标文件是target_file。它是应用程序实时写入的。
我要做的是,每个5秒钟,提取一次该日志文件中的内容,然后生成另一个文件,最后把这些文件都汇总。
# !/usr/地方/bin/python
utf - 8编码:
进口fileinput
导入的时间
进口操作系统
target_file=' user.log '
init_flag=True #初次加载程序
time_kick=5
record_count=0
而真正的:
打印“当前读到了’,record_count
#没有日志文件,等待
如果不是os.path.exists (target_file):
打印“target_file不存在”
time . sleep (time_kick)
继续
试一试:
ip=' 10.10.1.100 '
easytime=trftime (' % Y % m % d_ % H % m % S的,time.localtime ())
file_name=' % s_user_ % s。easytime日志' % (ip)
f_w=开放(file_name ' w ')
如果init_flag:
#读取整个文件
在fileinput.input eachline (target_file):
打印eachline
f_w.write (eachline)
record_count +=1
init_flag=False
其他:
#如果总行数小于当前行,那么认为文件更新了,从第一行开始读。
total_count=操作系统。popen (“wc - l % s % target_file) .read () .split () [0]
total_count=int (total_count)
如果total_count & lt;record_count:
record_count=0
在fileinput.input eachline (target_file):
line_no=fileinput.filelineno ()
如果line_no比;record_count:
打印eachline
f_w.write (eachline)
record_count +=1
f_w.close ()
除了:
通过
time . sleep (time_kick)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
