处理access_log与子流程的实时输出

Question

我想完成一个想法，我真的不知道该怎么做。基本上我试图捕捉通过grep命令的值如下所示

p = subprocess.Popen('tail -f /data/qantasflight/run/tomcat/logs/localhost_access_log.2016-02-29.txt | grep /qantas-ui/int/price?', stdout=subprocess.PIPE, shell = True) 
stdout = p.communicate()[0] 

过程中的标准输出值，然后按下值如下所示

f = urllib.urlopen("http://162.16.1.90:9140/TxnService", params2) 

param2的是值，其中i将处理结果由subprocess.Popen

给出简而言之我想以下：

- 等待新值 - > - 过程的值 - > - 推值 - >

这应该是实时的，python脚本将继续获取新值，处理它，然后推送该值。

Answer 1

我尝试代码somethink，只要你想，但我只是在打印日志新的生产线，您可以处理线，推动

from __future__ import print_function 
import subprocess 
from time import sleep 

f = open('test.log', 'r') 
while True: 
    line = '' 
    while len(line) == 0 or line[-1] != '\n': 
     tail = f.readline() 
     if tail == '': 
      continue 
     line = tail 

    print(line, end='') 

这种打印新的生产线，以安慰，只是编辑和使用:)也许我帮助你:)