XTY的小站
记录技术笔记和技术博客

weblog: 4.0 log_agent

07 Dec 2016

1. agent需要完成的功能

2. agent文件内容

log_agent.py

import subprocess
import select

import redis

r = redis.StrictRedis(host="127.0.0.1", port=6379)
filename = '/tmp/test.log'
f = subprocess.Popen(['tail','-F',filename],\
        stdout=subprocess.PIPE,stderr=subprocess.PIPE)
p = select.poll()
p.register(f.stdout)

# p.poll(timeout)
while True:
    if p.poll(1):
        r.publish('logchannel', f.stdout.readline())