4

我celery在我的一个django项目中使用它来执行一些任务。我最近需要添加一个periodic_task来更新我的一个模型中的对象的字段。所以我添加了periocdic_task如下。

import datetime
import logger.logger as logger

from celery.decorators import periodic_task



@periodic_task(run_every=datetime.timedelta(seconds=30))
def entries_about_to_expire():
   """ Changes the status of entries that are about to expire.
   """

   try:
       import entries.models as models
       startdate = datetime.datetime.today()
       enddate = startdate + datetime.timedelta(days=7)
       soon = models.EntryStatus.objects.get_or_create(
               name='Expiring Soon')[0]
       models.Entries.objects.filter(expiry_date__range=[startdate, enddate])\
               .update(status=soon)

   except Exception, err:
       logger.exception("Error while changing job status: %s" % (err))

接下来我做的是celery如下运行：

>>python manage.py celeryd -l info --beat

直到现在一切都运行良好。我什至可以看到任务是由 celery 发送的，如下所示（根据需要每 30 秒发生一次）。

[2013-11-15 15:01:10,690: INFO/MainProcess] Scheduler: Sending due task entries.tasks.entries_about_to_expire (entries.tasks.entries_about_to_expire)

但是由于某种原因，该任务没有执行。我的意思是我找不到对象的任何status变化Entries。我使用shell对此进行了测试。

In [2]: from entries.models import Entries, EntryStatus

In [3]: soon = EntryStatus.objects.get_or_create(name='Expiring Soon')[0]

In [4]: entries = Entries.objects.filter(status=soon)

In [5]: entries
Out[5]: []

即使在多次发送任务后，我也会得到相同的结果。我确信代码entries_about_to_expire运行良好，因为如果我手动调用它，它就可以工作。例如，如果我在 shell 中执行以下操作

In [6]: from entries.tasks import entries_about_to_expire

In [7]: entries_about_to_expire()

In [8]: entries = Entries.objects.filter(status=soon)

In [9]: Entries
Out[9]: [<Entries: 223>, <Entries: 512>, <Entries: 526>, <Entries: 591>]

那么为什么 celery 任务没有执行呢？任何线索？

注意：我也尝试过该celerybeat_schedule方法，但结果相同，即任务已发送但未执行

4

0 回答 0