为了解决日志文件监控的问题， 使用python脚本完成了基于关键字的告警功能

环境 python 2.7

依赖包 time \ traceback \ filelock \ logging

代码如下：

#!/bin/python
#coding:utf-8
import sys
reload(sys)
sys.setdefaultencoding('utf8')
import re
import os
from urllib import urlencode
import logging
import filelock
import time
import traceback

#config.conf
#文件1:关键字A|关键字B:出现次数:告警方式:联系方式:联系组:某某异常
#文件2:关键字C|关键字D:出现次数:告警方式:联系方式:联系组:某某异常

#rc.local增加
#sudo -u monitor /bin/bash -x /home/apps/logmon-job/deploy_py.sh

logging.basicConfig(level=logging.DEBUG,
          format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
          datefmt='%a, %d %b %Y %H:%M:%S',
          filename='/home/logs/monitor/logmon.log',
          #filename='/Users/mac/Desktop/logmon/logmon.log',
          filemode='a')

basDir='/home/apps/logmon-job/'

posFiles=basDir+'/pos.log'
configFile=basDir+'config.conf'

def readOnly(filename):
  return open(filename,'r')
  # pass

def readWrite(filename):
  return open(filename,'rw')
  # pass
def writeOnly(filename):
  return open(filename,'w')
  # pass

# def closesfile():
#   pass

def getStartPosLog(posFiles):
  txt=readOnly(posFiles)
  result={}
  for i in txt :
    filename,pos=i.split(':')
    if filename != '' :
      result[filename]=pos
  return result
  txt.close()

def rematch(txt,regular):
  resultList=[]
  for t in txt.split(r'\n') :
    # print t
    # pattern = re.compile(r':')
    pattern = re.compile(regular)

    resultList=(pattern.findall(t))
  try :
    # print '匹配结果为',resultList 
    return len(resultList),regular , resultList[0]
  except Exception as e :
    print e 
    return 0 , regular , ''
  # pass

def getEndPost(f):
  filename=readOnly(f)
  try :
    nowpos=filename.tell()
    filename.seek(0,2)
    endpos=filename.tell()
    filename.seek(nowpos,0)
  except :
    endpos = 0
  filename.close()
  return endpos 
  # pass

def getDistinct(startpos,endpos):
  return endpos-startpos

def getText(f,startpos,endpos):

  filename=readOnly(f)
  filename.seek(startpos,0)
  textLength=getDistinct(startpos,endpos)
  text=filename.read(textLength)
  filename.close()
  return text

def updatePosLog(posResult,posFiles):
  f=writeOnly(posFiles)
  # print 'posResult ',posResult
  for k in posResult.keys() :
    v=posResult[k]
    f.writelines('%s:%s\n' %(k,v))
  f.close()

  pass

def getAlterConfi(filename):
  #文件:关键字:出现次数:告警方式:联系方式:联系组
  f=readOnly(filename)
  result={}
  for lines in f.readlines():
    # print lines
    try :
      filename , key , count , alterType , alterAddress , alterGroup ,alterMessage= lines.strip('\n').split(":")
      result[filename]={}
      result[filename]["key"]     =key
      result[filename]["count"]    =count
      result[filename]["alterType"]  =alterType
      result[filename]["alterAddress"]=alterAddress
      result[filename]["alterGroup"] =alterGroup
      result[filename]["alterMessage"]=alterMessage
    except Exception as e:
      print e
      print '错误的配置 %s' % (lines.strip('\n'))
      pass
  return result

def sendSms(account,message):

  data={
    'accounts':account ,
    'templateName':'opalert' ,
    'alertcontent':message ,
  }
  encodeMessage=urlencode(data)

  #正式时需要开启
  os.system('curl -I "http://10.1.1.146:8080/sms/send?%s" ' % ( encodeMessage ) )

def main():
  global posFiles
  global configFile

  AlterConfi=getAlterConfi(configFile)
  print AlterConfi
  posResult=getStartPosLog(posFiles)
  posResult_bak=getStartPosLog(posFiles)
  # print posResult
  for filename in AlterConfi.keys() :
    keyDict=AlterConfi[filename]
    print '开始检查文件 ',filename
    #print rematch(filename,r'#')[0] 
    if not os.path.exists(filename):
      print 'file "%s" not exist ,pass' % (filename)
      # continue
    if os.path.exists(filename):

      
      endpos = getEndPost(filename)

      if endpos == 0 :
        print 'file "%s" is empty ,pass' % (filename)
      else :
        try :
          startpos= int(posResult[filename])
        except :
          startpos = 0
        print 'startpos is %.f , endpos is %.f' %(startpos ,endpos)

        #处理切割后，偏移量归位
        if startpos > endpos :
          startpos = 0

        text = getText(filename,startpos,endpos)
        # print '%s text is : '%(filename) , text

        #分析关键字
        #print AposlterConfi[filename]
        matchCount , regular , resultList = rematch(text,keyDict['key'])
        print '匹配关键字',regular , '匹配长度为', matchCount , '关键字告警阈值' ,keyDict['count'] , '关键字' , resultList

        if int(matchCount) >= int(keyDict['count']) :
          print 'alterGroup len is ',len(keyDict['alterGroup'])
          print 'alterType len is ' ,len(keyDict['alterType'])
          if len(keyDict['alterGroup']) > 0:
            pass
          if len(keyDict['alterType']) >0:
            if keyDict['alterType'].upper() == 'SMS' :
              for account in keyDict['alterAddress'].split(',') :
                if len(account) >0 :
                  sendSms(account,'发现%s 告警，关键字:%s ,出现次数:%s ' %(keyDict['alterMessage'] , resultList , matchCount ))
            pass
        #记录末尾偏移量
        posResult_bak[filename]=endpos


    
  print '打印文件偏移量信息',posResult_bak
    
  #正式时需要开启
  updatePosLog(posResult_bak,posFiles)


if __name__ == '__main__':
  lock = filelock.FileLock("/home/apps/logmon-job/logmon.py.lock")
  if lock:
    logging.info("CaiWeiCheng Get Lock.start!!!")
  try:
    with lock.acquire(timeout=5):
      while 1 :
        main()
        time.sleep(60)
      # pass
  #except filelock.timeout :
  except Exception as e :
    print traceback.format_exc()
    print "timeout"     
    logging.warning("get file lock timeout")

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

# Python关键字  # Python关键字监控  # Python关键字告警  # Python中关键字nonlocal和global的声明与解析  # Python爬虫：通过关键字爬取百度图片  # Python 中的with关键字使用详解  # 深入解析Python编程中super关键字的用法  # 编写Python小程序来统计测试脚本的关键字  # Python查询阿里巴巴关键字排名的方法  # python关键字and和or用法实例  # Python中super关键字用法实例分析  # Python中关键字is与==的区别简述  # phpsir 开发 一个检测百度关键字网站排名的python 程序  # 偏移量  # 时需  # 大家多多  # 长度为  # 完成了  # filemode  # basDir  # mac  # Desktop  # pos  # configFile  # log  # posFiles  # lineno  # levelname  # filename  # line  # message  # asctime  # Users 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 成都品牌网站制作公司,成都营业执照年报网上怎么办理？  Laravel如何使用Blade模板引擎？（完整语法和示例）  微博html5版本怎么弄发语音微博_语音录制入口及时长限制操作【教程】  如何在不使用负向后查找的情况下匹配特定条件前的换行符  Laravel怎么解决跨域问题_Laravel配置CORS跨域访问  Laravel如何优雅地处理服务层_在Laravel中使用Service层和Repository层  如何在IIS7中新建站点？详细步骤解析  香港服务器建站指南：外贸独立站搭建与跨境电商配置流程  Laravel怎么发送邮件_Laravel Mail类SMTP配置教程  韩国网站服务器搭建指南：VPS选购、域名解析与DNS配置推荐  网页设计与网站制作内容,怎样注册网站？  电视网站制作tvbox接口,云海电视怎样自定义添加电视源？  Laravel项目结构怎么组织_大型Laravel应用的最佳目录结构实践  如何用PHP快速搭建CMS系统？  如何在云主机快速搭建网站站点？  ai格式如何转html_将AI设计稿转换为HTML页面流程【页面】  Laravel的.env文件有什么用_Laravel环境变量配置与管理详解  如何在建站宝盒中设置产品搜索功能？  北京企业网站设计制作公司,北京铁路集团官方网站？  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  Python并发异常传播_错误处理解析【教程】  Laravel怎么使用Collection集合方法_Laravel数组操作高级函数pluck与map【手册】  Firefox Developer Edition开发者版本入口  在线制作视频的网站有哪些,电脑如何制作视频短片？  Laravel如何与Pusher实现实时通信？（WebSocket示例）  使用PHP下载CSS文件中的所有图片【几行代码即可实现】  如何确保FTP站点访问权限与数据传输安全？  如何在 Go 中优雅地映射具有动态字段的 JSON 对象到结构体  JavaScript中如何操作剪贴板_ClipboardAPI怎么用  ,南京靠谱的征婚网站？  Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】  作用域操作符会触发自动加载吗_php类自动加载机制与::调用【教程】  如何用PHP快速搭建高效网站？分步指南  高性价比服务器租赁——企业级配置与24小时运维服务  Laravel如何实现URL美化Slug功能_Laravel使用eloquent-sluggable生成别名【方法】  中山网站推广排名,中山信息港登录入口？  Python函数文档自动校验_规范解析【教程】  企业网站制作这些问题要关注  如何用西部建站助手快速创建专业网站？  Laravel如何使用Service Provider服务提供者_Laravel依赖注入与容器绑定【深度】  Laravel Sail是什么_基于Docker的Laravel本地开发环境Sail入门  Python图片处理进阶教程_Pillow滤镜与图像增强  焦点电影公司作品,电影焦点结局是什么？  ,网页ppt怎么弄成自己的ppt？  音响网站制作视频教程,隆霸音响官方网站？  高防服务器租用首荐平台，企业级优惠套餐快速部署  C++用Dijkstra(迪杰斯特拉)算法求最短路径  如何在服务器上三步完成建站并提升流量？  三星、SK海力士获美批准：可向中国出口芯片制造设备  JavaScript如何实现类型判断_typeof和instanceof有什么区别