Celery v4.2.1+RabbitMQ中apply_async的ETA格式异常致任务未执行

我之前碰到过几乎一模一样的坑，核心问题出在你传入的eta是无时区信息的本地datetime对象，Celery对这种"朴素"时间的处理逻辑和你预期的不一致，才导致任务迟迟不执行。

问题拆解 #

你用datetime.datetime.now()生成的时间是不带时区标记的（业内叫naive datetime），虽然你以为设置的是UTC时间，但Celery默认会把这个时间直接当作UTC处理——如果你的本地时区不是UTC，实际计算出的ETA就会完全偏差。比如你本地是东八区，你想设置"5分钟后"，但这个时间在Celery眼里是UTC的8小时前+5分钟，任务早就过期了，自然不会触发。另外Flower里显示的带T的格式是ISO 8601标准格式，这是正常的显示方式，不是问题根源。

正确解决方案 #

Celery的eta参数只接受带时区信息的datetime对象，手动修改字符串格式完全没用，你得生成正确的时间对象才行，这里有两种可靠的写法：

方法1：用pytz库（兼容所有Python版本）

先安装依赖：

pip install pytz

然后修改代码：

import datetime
import pytz

# 生成带UTC时区标记的当前时间，再加5分钟
utc_now = datetime.datetime.now(tz=pytz.utc)
eta_time = utc_now + datetime.timedelta(minutes=5)
RunScheduledScrape.apply_async(args=[program.id, new_task.id], eta=eta_time)

方法2：用Python 3.9+内置的zoneinfo

如果你的Python版本在3.9及以上，不需要额外装库：

import datetime
from zoneinfo import ZoneInfo

utc_now = datetime.datetime.now(tz=ZoneInfo("UTC"))
eta_time = utc_now + datetime.timedelta(minutes=5)
RunScheduledScrape.apply_async(args=[program.id, new_task.id], eta=eta_time)

额外验证点 #

1. 确认你的Celery配置里设置了timezone = 'UTC'，保持和ETA的时区一致，彻底避免时区混乱。
2. 任务提交后去Flower里看ETA是否是你预期的UTC时间（比如你本地是UTC+8的10:00，那ETA应该显示UTC的02:05），只要时间对应上，到点任务就会正常执行。

内容的提问来源于stack exchange，提问作者Ketan Modi