将 Apscedular 作业异常捕获到 Sentry

Question

我正在使用 apscheduler 在后台处理一些事情。

我想捕获并向 Sentry 报告可能的异常。我的代码如下所示：

sentry = Client(dsn=SENTRY_DSN)

def sample_method():
     # some processing..

     raise ConnectionError

def listen_to_exceptions(event):
    if event.exception:
        # I was hoping raven will capture the exception using  sys.exc_info(), but it's not
        sentry.captureException()


scheduler = BlockingScheduler()

scheduler.add_listener(listen_to_exceptions, EVENT_JOB_EXECUTED | EVENT_JOB_ERROR)

scheduler.add_job(sample_method, 'interval', minutes=5, max_instances=1)

# run forever!!!
scheduler.start()

但它不是捕获异常，而是生成更多异常，试图将其报告给 Sentry。

ConnectionError
Error notifying listener
Traceback (most recent call last):
  File "/.../venv/lib/python3.6/site-packages/apscheduler/schedulers/base.py", line 825, in _dispatch_event
    cb(event)
  File "app.py", line 114, in listen_to_exceptions
    sentry.captureException(event.exception)
  File "/.../venv/lib/python3.6/site-packages/raven/base.py", line 814, in captureException
    'raven.events.Exception', exc_info=exc_info, **kwargs)
  File "/.../venv/lib/python3.6/site-packages/raven/base.py", line 623, in capture
    if self.skip_error_for_logging(exc_info):
  File "/.../venv/lib/python3.6/site-packages/raven/base.py", line 358, in skip_error_for_logging
    key = self._get_exception_key(exc_info)
  File "/.../venv/lib/python3.6/site-packages/raven/base.py", line 345, in _get_exception_key
    code_id = id(exc_info[2] and exc_info[2].tb_frame.f_code)
TypeError: 'ConnectionError' object is not subscriptable

我正在尝试根据 docs 使用事件侦听器。 是否有其他方法可以捕获已执行作业中的异常？

当然，我可以为每个作业函数添加 try except 块。我只是想了解是否有办法用 apscedular 来做到这一点，因为我有 20 多个工作并且在每个地方添加 sentry.captureException() 似乎都是重复。

Answer 1

你只需要捕获EVENT_JOB_ERROR。此外，sentry.captureException() 需要一个 exc_info 元组作为其参数，而不是异常对象。以下将适用于 Python 3:

def listen_to_exceptions(event):
    exc_info = type(event.exception), event.exception, event.exception.__traceback__
    sentry.captureException(exc_info)

scheduler.add_listener(listen_to_exceptions, EVENT_JOB_ERROR)

Answer 2

文档已 updated。所以你必须按照以下方式进行：

from sentry_sdk import capture_exception
....
def sentry_listener(event):
    if event.exception:
        capture_exception(event.exception)

scheduler.add_listener(sentry_listener, EVENT_JOB_ERROR)

将 Apscedular 作业异常捕获到 Sentry

Capturing Apscedular job exceptions to Sentry

python

python-3.x

sentry

apscheduler