python - 如何在 Celery 任务中使用自动重试记录异常

Question

来自 celery 文档，

If you want to automatically retry on any error, simply use:

@app.task(autoretry_for=(Exception,))
def x():
    ...

我们如何记录它重试的异常？如果我们有一个 try-except，添加日志就很容易了，例如

@app.task(bind=True, default_retry_delay=30 * 60)  # retry in 30 minutes.
def add(self, x, y):
    try:
        something_raising()
    except Exception as exc:
        logger.info('Retry for exception %s', exc)
        # overrides the default delay to retry after 1 minute
        raise self.retry(exc=exc, countdown=60)

但我想使用 autoretry，这样我就可以利用 autoretry 附带的 celery 重试退避，而不是使用 try-except 实现我自己的倒计时。请帮忙。

Answer 1

在声明任务时添加throws 参数，这将在屏幕上弹出异常，它可以更改为您想要抛出的任何预期异常。例如RequestException、TimeoutException

@app.task(bind=True, throws=(Exception,), default_retry_delay=30 * 60)  # retry in 30 minutes.
def add(self, x, y):
    ...