python实时过滤日志脚本

julley

　　大神指导作品：
　　#!/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'))