autoretry_for仅触发重试，不控制延迟；需配合retry_backoff实现指数退避，如retry_backoff=2表示第n次重试延迟2**n秒，retry_jitter=True添加随机偏移，max_retries设硬上限，且仅捕获指定异常。
autoretry_for 不等于自动指数退避，它只负责“抛出重试”，不控制“等多久”。真要阶梯式重试，必须手动算 countdown 或启用 retry_backoff 参数。
autoretry_for + retry_backoff 是最简阶梯重试方案
这是开箱即用的组合，适合网络类临时错误。它把指数退避逻辑封装进框架层，不用手写 self.retry()。
-
retry_backoff=2表示第 1 次重试延迟 2 秒，第 2 次延迟 4 秒，第 3 次延迟 8 秒……即2 ** n -
retry_jitter=True（默认开启）会加随机偏移，避免所有任务在同一时刻重试打爆下游 -
max_retries=5是硬上限，超过后抛MaxRetriesExceededError，不再重试 - 注意：
autoretry_for只捕获指定异常类型，ValueError这类编程错误不会触发重试
示例：
@shared_task(
bind=True,
autoretry_for=(requests.RequestException, redis.ConnectionError),
retry_backoff=2,
retry_jitter=True,
max_retries=4
)
def fetch_data(self, url):
return requests.get(url, timeout=8).json()
手动 self.retry() 才能精确控制退避行为
当需要动态调整延迟、加最大上限、或根据错误类型差异化退避时，autoretry_for 就不够用了。必须用 bind=True 获取 self.request.retries，再自己算 countdown。
立即学习“Python免费学习笔记（深入）”；
- 不加
bind=True→self不可用 → 拿不到重试次数 → 无法实现指数逻辑 -
countdown单位是秒，必须是数字，不能是timedelta - 别用全局变量或缓存存重试次数，Celery worker 是无状态的，每次调用都是新上下文
- 建议加
max_delay上限，防止第 10 次重试等 1024 秒（约 17 分钟）
安全写法示例：
@app.task(bind=True)
def send_email(self, user_id):
try:
send_mail_to_user(user_id)
except SMTPServerDisconnected as exc:
base = 2 ** self.request.retries
countdown = min(base, 60) # 最多等 60 秒
raise self.retry(exc=exc, countdown=countdown)
task_acks_late 和 task_reject_on_worker_lost 决定重试是否真正生效
很多任务看似配置了重试，却只执行一次就失败了——问题常出在 ACK 机制上。
-
task_acks_late=True：任务执行完才发 ACK，否则 Worker 崩溃时任务就丢了 -
task_reject_on_worker_lost=True：Worker 被杀或崩溃时，任务自动拒收并重回队列（需 Broker 支持，如 RabbitMQ） - Redis 作为 Broker 时，
task_reject_on_worker_lost无效，得靠visibility_timeout和重入队逻辑兜底 - 如果用了
acks_late=False（默认），任务一取走就 ACK，Worker 挂了任务就永久消失
退避参数别硬编码，从 settings 或环境变量读取
线上改个重试间隔要发版？没必要。把策略参数抽出来，运行时加载更灵活。
- Django 项目可在
settings.py定义：
CUSTOM_RETRY_POLICY = {
'max_retries': int(os.getenv('CELERY_MAX_RETRIES', '3')),
'base_delay': float(os.getenv('CELERY_BASE_DELAY', '1')),
'max_delay': int(os.getenv('CELERY_MAX_DELAY', '120')),
}
- 任务里直接读取，和业务逻辑解耦：
@app.task(bind=True)
def call_third_api(self, payload):
cfg = getattr(settings, 'CUSTOM_RETRY_POLICY', {})
try:
requests.post('https://api.example.com', json=payload, timeout=5)
except Exception as exc:
delay = min(cfg['base_delay'] * (2 ** self.request.retries), cfg['max_delay'])
raise self.retry(exc=exc, countdown=delay)
真正容易被忽略的是：重试不是万能的，它掩盖不了设计缺陷。比如数据库事务没回滚、幂等性没做、下游根本不可用——这些场景下重试只会放大问题。先确保单次执行健壮，再谈重试策略。
