python实时过滤日志脚本

标签：python

大神指导作品：

#!/usr/bin/python
#coding:utf8

from functools import wraps
from time import sleep
import os

RESTART=‘pm2 restart ios-push‘


# coroutine 先要用 next 语句调用一次
def coroutine(fn):
    @wraps(fn)
    def wrapper(*args,**kwargs):
        ret=fn(*args,**kwargs)
        next(ret)
        return ret
    return wrapper

def follow(file,target):
    ‘‘‘
    类似 Unix 的 tail -f, 但是接受一个 target, 有新的数据，交给 target 处理
    ‘‘‘
    file.seek(0,2)# 直接到文件的最后一行，类似 tail -f -n 0
    while True:
        line=file.readline()#读取行
        if not line:
            sleep(0.5)# 如果是空行，直接 sleep 0.5s，然后 continue
            continue
        target.send(line)# 如果有新数据，则交给 target 处理

def action():
   if os.system(RESTART) == 0:
       print(‘ios-push restart success!‘)
    #print(‘restart‘)

@coroutine
def grep(pattern):
     ‘‘‘
    grep 是一个 coroutine，接受一个 pattern 参数，需要从外部 send 数据 ,如果接受的数据匹配 pattern 通过了，则调用action函数
    ‘‘‘
    while True:
        line = yield
        if pattern in line:
            action()
if __name__ == ‘__main__‘:
    follow(open(‘error.log‘,‘r‘),grep(‘MaxListenersExceededWarn‘))

python实时过滤日志脚本

标签：python

原文地址：http://yanruohan.blog.51cto.com/9740053/1949417