当我将 Django Celery apply_async 与 eta 一起使用时，它会立即完成工作

Question

我查看了 celery 文档并从中尝试了一些东西，但它不像示例那样工作。也许我在某些时候错了，如果我对以下代码有误，请给我一些指导

在views.py中我有这样的东西：

class Something(CreateView):
  model = something

  def form_valid(self, form):
    obj = form.save(commit=False)
    number = 5
    test_limit = datetime.now() + timedelta(minutes=5)
    testing_something.apply_async((obj, number), eta=test_limit)
    obj.save()

在芹菜任务中我写了这样的东西：

@shared_task()
def add_number(obj, number):
    base = Base.objects.get(id=1)
    base.add = base.number + number
    base.save()
return obj

我使用此代码的条件是 celery 在 CreateView 运行后立即运行，我的目标是在运行 Something CreateView 后 5 分钟内运行一次任务 add_number。非常感谢

编辑：

1. 我已尝试将eta 更改为countdown=180，但它仍会立即运行add_number 功能。我也尝试过更长的倒计时，但仍会立即运行
2. 我试过@johnmoustafis 的回答，但还是一样，任务立即运行
3. 我也试过@dana 的回答，但还是一样，任务立即运行

Answer 1

Celery 默认使用 UTC 时间。
如果您的时区“落后”于 UTC（UTC - HH:MM），datetime.now() 调用将返回一个“落后于”UTC 的时间戳，从而导致您的任务立即执行。

您可以改用datetime.utcnow()：

test_limit = datetime.utcnow() + timedelta(minutes=5)

---

由于您使用的是 django，因此存在另一种选择：

如果您在setting.py 中设置了USE_TZ = True，则您已启用django timezone settings，您可以使用timezone.now() 代替datetime.utcnow()：

from django.utils import timezone

...

test_limit = timezone.now() + timedelta(minutes=5)

Answer 2

'test_limit' 变量没有时区信息。所以 Celery 会将 eta 参数理解为 UTC 时间。

请使用修改后的代码：

class Something(CreateView):
    model = something

    def form_valid(self, form):
        obj = form.save(commit=False)
        number = 5

        test_limit = datetime.now()
        test_limit = test_limit.replace(tzinfo=tz.tzlocal())
        test_limit = test_limit + timedelta(minutes=5)

        testing_something.apply_async((obj, number), eta=test_limit)
        obj.save()

Answer 3

您可能有CELERY_ALWAYS_EAGER=True 设置。

您能否也发布您的配置和您正在使用的 Celery 版本？

Here你可能会找到一些有用的信息。