Django怎么实现自动任务重试_Python结合Celery配置指数退避策略-Python教程-PHP中文网

Celery 的 retry 不自动指数退避，因其默认 countdown=0 且无内置退避逻辑；必须显式传入 countdown 参数并结合 self.request.retries 手动实现，如 countdown = 2 ** self.request.retries。

django怎么实现自动任务重试_python结合celery配置指数退避策略

为什么 Celery 的 `retry` 不自动指数退避？

Celery 默认的 retry 只是立即重试，不带任何延迟逻辑。你调用 self.retry() 却发现任务一秒内连跑五次，不是因为配置漏了，而是它压根没内置退避——得手动算延迟时间。

常见错误现象：MaxRetriesExceededError 比预期早得多；日志里看到重试间隔全是 0s 或固定值；服务端被下游接口瞬间打挂。

必须显式传入 countdown 参数，否则默认为 0
指数退避得自己实现：比如第 1 次等 1s，第 2 次等 2s，第 3 次等 4s……常用公式是 2 ** max_retries_attempted
Django settings 里的 task_acks_late 和 task_reject_on_worker_lost 会影响重试是否真正触发，别只盯 retry 参数

怎么在 task 函数里写安全的指数退避重试？

核心是把重试逻辑收进函数体，用 self.request.retries 获取当前重试次数，再算出下次 delay。别依赖外部状态或全局变量，Celery worker 是无状态的。

@app.task(bind=True, autoretry_for=(requests.RequestException,), retry_kwargs={'max_retries': 3})
def fetch_remote_data(self, url):
    try:
        return requests.get(url, timeout=5).json()
    except requests.RequestException as exc:
        countdown = 2 ** self.request.retries
        raise self.retry(exc=exc, countdown=countdown)

bind=True 必须加，否则拿不到 self.request
autoretry_for 只负责自动抛出 retry，不控制 delay，delay 还得靠 self.retry() 显式传
如果用了 retry_kwargs，注意它和手动 self.retry() 共存时，max_retries 是叠加判定的，容易误超限

Django 中如何让重试策略可配置、不硬编码？

把退避参数从代码里抽出来，放到 Django settings 或环境变量里，否则改个重试间隔就得发版。

例如在 settings.py 加：

Python Hardener

通过完整的安全审查、代码整洁重构、健壮的错误处理、正确的日志记录以及完整的文档字符串覆盖，强化 Python 脚本。

下载

CUSTOM_RETRY_BACKOFF = {
    'max_retries': 5,
    'base_delay': 1,  # 秒
    'max_delay': 60,   # 上限防雪崩
}

然后 task 里读取：

@app.task(bind=True)
def send_notification(self, user_id):
    from django.conf import settings
    cfg = settings.CUSTOM_RETRY_BACKOFF
    try:
        send_email(user_id)
    except EmailSendError as exc:
        delay = min(cfg['base_delay'] * (2 ** self.request.retries), cfg['max_delay'])
        raise self.retry(exc=exc, countdown=delay)