日志记录不工作在tornado.concurrent.Future的回调中

Question

我正在使用apscheduler的龙卷风调度器。每当任务被调用时，我都需要记录它的例外情况。为了处理异常，我创建了一个装饰器，它将获得未来的对象并将采取适当的行动。它工作正常，但它不会记录未来的回调函数。我在回调中完成了Pdb，并且记录器实例属性如预期的那样，但它根本不记录文件。 守则，

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

Answer 1

包装缺少未来的回报 - 没有这个，如果会有一些异步调用，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 

如果有任何其他的问题，我相信它的相关记录配置/设置。