cxg518 发表于 2018-8-15 12:10:56

分析/var/log/message的python脚本

  使用该程序分析/var/log/message中有error或者其他错误关键字。并在发现后搜集,发送邮件运维管理人员。
  可以再定义一下辅助的函数,比如说获取服务器的ip地址。放在邮件内容中。一起发邮件。
  #!/usr/bin/env/python
  #coding:utf8
  import commands
  import os,sys
  import datetime
  import time
  #import file_seekwork
  import urllib,urllib2
  import json
  today=datetime.date.today()
  MONTH={
  'Jan':1,
  'Feb':2,
  'Mar':3,
  'Apr':4,
  'May':5,
  'Jun':6,
  'Jul':7,
  'Aug':8,
  'Sep':9,
  'Oct':10,
  'Nov':11,
  'Dec':12
  }
  def parse_file():
  pass
  #获取文件修改时间
  def get_state(file):
  file_mtime=os.stat(file).st_mtime
  return file_mtime
  #查看/var/log/message 是否在10分钟之内修改过,如果修改过返回file。
  def getenfile(file,nowtime):
  if os.path.exists(file) and (nowtime-get_stat(file))/60 < 10:
  return file
  #
  def parse_date(datestr):
  year=today.year
  month,day,yearandtime=datestr.split("/")
  hour,minute,second = yearandtime.split(":")
  return datetime.datetime(int(year),MONTH,int(day),int(hour),int(minute))
  #获取10分钟的日志,并分析是否存在关键字nologmsg,如果有,便存入logmsg中。
  def get_msg_result(time_minutes_ago,file,nologmsg):
  with open(file) as fd:
  y = fd.readlines()
  logmsg=[]
  logerrmsg=[]
  for line in y:
  splited_line=line.split()
  datestr = '/'.join(splited_line[:3])
  #print ("datestr qqqqqq: %s"%datestr)
  try:
  date_str=parse_date(datestr)
  #print ("date_str: %s" %date_str)
  except:
  continue
  #date = date_str.strftime("%s")
  #print date_str,time_minutes_ago
  if date_str >= time_minutes_ago:
  logmsg.append(line)
  else:
  continue
  for ten_minutes_line in logmsg:
  for i in nologmsg:
  if i not in line:
  continue
  else:
  logerrmsg.append(ten_minutes_line)
  if logerrmsg:
  continue
  #for errline in logerrmsg:
  #    print errline
  return logerrmsg
  if __name__ == '__main__':
  now = datetime.datetime.now()
  #print now
  d = datetime.timedelta(minutes=10)
  #print d
  time_minutes_ago=now - d
  #print time_minutes_ago
  keyword = ['error']
  log_file= '/root/qh/qh_test.txt'
  retrust= get_msg_result(time_minutes_ago,log_file,keyword)
  print(112,retrust)
  # 发邮件
  receiver = 'xxx@xxx.xxx'
  subject = '/var/log/messages error'
  a=''.join(retrust)
  print a
  #print type(a)
  #a="adfasdfasdfasdf"
  #os.system ('/usr/bin/perl /root/qh/send_msg.pl -t' + receiver+ '-s' + subject + '-c' + 'test_qh')
  commands.getoutput('/usr/bin/perl /root/qh/send_msg.pl -t %s -s "%s" -c "%s" '%(receiver,subject,a))
页: [1]
查看完整版本: 分析/var/log/message的python脚本