3

我想将日志消息重定向到某种处理方法（例如，为了将所有消息保存在队列中）。目前我正在尝试使用 logging.StreamHandler 来写入 StringIO 然后在其他地方读取它。在我的情况下，这可能是一个从流中连续读取的线程，但它也可能是在每个日志条目上调用的回调方法。

import threading
import time
import sys
import logging
from StringIO import StringIO

# this thread shall read from a stream 
# continuously and 
def tread_fn( stream ):
    while not stream.eof():       <=== this is not valid but my current approach
        l = stream.readline()
        do_something( l )

stream = StringIO()

handler = logging.StreamHandler(stream)
log = logging.getLogger()
log.setLevel( logging.INFO )

# replace all log handlers
for handler in log.handlers: 
    log.removeHandler(handler)
log.addHandler(handler)

thread = threading.Thread(target = tread_fn, args=[stream])
thread.start()

for i in range(3):        
    time.sleep(1)
    log.error("test")          <=== should be handled line by line

我觉得我忽略了非常明显和简单的最佳实践，但我现在挣扎了一段时间:) 也许我根本不需要流，但目前我什至无法写入流并在某处读取它否则..所以简而言之，我的问题是：

  • 主要目标是如何实现python方式的？

  • 如何将字符串写入流并在另一个线程中连续读取？

4

1 回答 1

0

您已将两个问题合二为一——它们应该是单独的问题。您的主要目标可以使用例如 a 来实现QueueHandler，它在 Python 3.2 及更高版本中可用，但也可用于通过项目的早期 Python 版本logutils。

于 2013-08-24T10:53:14.717 回答