日志记录不工作在tornado.concurrent.Future的回调中
问题描述:
我正在使用apscheduler的龙卷风调度器。每当任务被调用时,我都需要记录它的例外情况。为了处理异常,我创建了一个装饰器,它将获得未来的对象并将采取适当的行动。它工作正常,但它不会记录未来的回调函数。我在回调中完成了Pdb,并且记录器实例属性如预期的那样,但它根本不记录文件。 守则,日志记录不工作在tornado.concurrent.Future的回调中
logger = logging.getLogger('myLogger')
def handle_callback(result):
logger.debug(result.result())
logger.info(result.result())
logger.error(result.result())
logger.exception(result.result())
logger.exception(result.exc_info())
def handle_exceptions():
def wrapped(fn):
@wraps(fn)
def wrapper(*args, **kwargs):
future = fn(*args, **kwargs)
future.add_done_callback(handle_callback)
return wrapper
return wrapped
@handle_exceptions()
@gen.coroutine
def run_task(job_id):
logger.info('executing job {}'.format(job_id))
raise MyException
附:我正在使用python2.7
答
包装缺少未来的回报 - 没有这个,如果会有一些异步调用,ioloop将不会继续。让我们添加一些异步调用
@handle_exceptions
@gen.coroutine
def run_task(job_id):
logger.info('executing job {}'.format(job_id))
yield gen.sleep(1)
raise Exception('blah')
正如你可能注意到,我已经移除装饰()
简化它。它不必嵌套。所以装饰看起来是这样:
def handle_exceptions(fn):
@wraps(fn)
def wrapper(*args, **kwargs):
future = fn(*args, **kwargs)
future.add_done_callback(handle_callback)
return future # <<< we need this
return wrapper
接下来,该处理的回调呼吁Future.result()
将立即重新引发异常。所以最好是检查是否有摆在首位的异常:
def handle_callback(result):
exc_info = result.exc_info()
if exc_info:
logger.error('EXCEPTION %s', exc_info)
在简单的例子放在一起这样的:
import logging
from functools import wraps, partial
from tornado import gen, ioloop
logger = logging.getLogger()
logger.setLevel(logging.INFO)
def handle_callback(result):
exc_info = result.exc_info()
if exc_info:
logger.error('EXCEPTION %s', exc_info)
def handle_exceptions(fn):
@wraps(fn)
def wrapper(*args, **kwargs):
future = fn(*args, **kwargs)
future.add_done_callback(handle_callback)
return future
return wrapper
@handle_exceptions
@gen.coroutine
def run_task(job_id):
logger.info('executing job {}'.format(job_id))
yield gen.sleep(1)
raise Exception('blah')
ioloop.IOLoop.instance().run_sync(partial(run_task, 123))
由于问题本身不提供有关记录任何信息,我已经使用了改变了水平的标准。 代码输出:
INFO:root:executing job 123
ERROR:root:EXCEPTION (<type 'exceptions.Exception'>, Exception('blah',), <traceback object at 0x7f807df07dd0>)
Traceback (most recent call last):
File "test.py", line 31, in <module>
ioloop.IOLoop.instance().run_sync(partial(run_task, 123))
File "/tmp/so/lib/python2.7/site-packages/tornado/ioloop.py", line 458, in run_sync
return future_cell[0].result()
File "/tmp/so/lib/python2.7/site-packages/tornado/concurrent.py", line 238, in result
raise_exc_info(self._exc_info)
File "/tmp/so/lib/python2.7/site-packages/tornado/gen.py", line 1069, in run
yielded = self.gen.send(value)
File "test.py", line 28, in run_task
raise Exception('blah')
Exception: blah
如果有任何其他的问题,我相信它的相关记录配置/设置。
然而,我已经使用'yield'(在调用者中)和'gen.Return'(在被调用者中)一起使用。我可以在'try except'块中处理异常。它会像正常的“同步”执行一样好吗?供参考 - > https://gist.github.com/pranav93/3c34d6cfc2b5d8956625e4cd66bdfa34 – pnv