python实现定时提取实时日志程序

时间:2021-10-24 15:19:03

本文实例为大家分享了python定时提取实时日志的具体代码,供大家参考,具体内容如下

这是一个定时读取 实时日志文件的程序。目标文件是target_file. 它是应用程序实时写入的。

我要做的是,每个5秒钟,提取一次该日志文件中的内容,然后生成另一个文件,最后把这些文件都汇总。

?
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
#!/usr/local/bin/python
# coding:utf-8
 
import fileinput
import time
import os
 
target_file = 'user.log'
init_flag = True # 初次加载程序
time_kick = 5
 
record_count = 0
 
while True:
 print '当前读到了', record_count
 #没有日志文件,等待
 if not os.path.exists(target_file):
 print 'target_file not exist'
 time.sleep(time_kick)
 continue
 
 try:
 ip = '10.10.1.100'
 easytime = time.strftime('%Y%m%d_%H%M%S', time.localtime())
 file_name = '%s_user_%s.log' % (ip,easytime)
 f_w = open(file_name, 'w')
 if init_flag:
  #读取整个文件
  for eachline in fileinput.input(target_file):
  print eachline
  f_w.write(eachline)
  record_count += 1
 
  init_flag = False
 else:
  #如果总行数小于当前行,那么认为文件更新了,从第一行开始读。
  total_count = os.popen('wc -l %s' % target_file).read().split()[0]
  total_count = int(total_count)
  if total_count < record_count:
  record_count = 0
 
  for eachline in fileinput.input(target_file):
  line_no = fileinput.filelineno()
  if line_no > record_count:
   print eachline
   f_w.write(eachline)
   record_count += 1
 
 f_w.close()
 except:
 pass
 time.sleep(time_kick)

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

原文链接:https://blog.csdn.net/weixin_37887248/article/details/80727560