python - 如何为 Celery 任务实现自动重试

Question

在 Celery 中，如果出现异常，您可以重试任何任务。你可以这样做:

@task(max_retries=5)
def div(a, b):
    try:
        return a / b
    except ZeroDivisionError, exc:
        raise div.retry(exc=exc)

在这种情况下，如果你想除以零，任务将被重新执行五次。但是您必须显式检查代码中的错误。如果您跳过 try-except block ，任务将不会重新启动。

我希望我的函数看起来像:

@celery.task(autoretry_on=ZeroDivisionError, max_retries=5)
def div(a, b):
    return a / b

Answer 1

Celery(从 4.0 版开始)正是您要找的东西:

@app.task(autoretry_for=(SomeException,))
def my_task():
    ...

参见:http://docs.celeryproject.org/en/latest/userguide/tasks.html#automatic-retry-for-known-exceptions