celery - 芹菜节拍不能正常工作

Question

当我为 celery beat 运行这个命令时。

[2013-06-27 02:17:05,936：INFO/MainProcess] Celerybeat：开始...

[2013-06-27 02:17:05,937: INFO/MainProcess] 写条目...

[2013-06-27 02:17:08,711：INFO/MainProcess] DatabaseScheduler：计划已更改。

[2013-06-27 02:17:08,712: INFO/MainProcess] 写条目...

它被困在这个结果上。但在我的 settings.py 中，我配置了 CELERYBEAT_SCHEDULE。

CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler"

from datetime import timedelta

CELERYBEAT_SCHEDULE = {
    'add-every-30-seconds': {
    'task': 'celerytest.tasks.add',
    'schedule': timedelta(seconds=30),
    'args': (16, 16)
    },

    'add-every-10-seconds': {
    'task': 'celerytest.tasks.minus',
    'schedule': timedelta(seconds=10),
    'args': (20, 16)
    },

}

我的芹菜节拍有什么问题？

Answer 1

该celery beat命令启动celery 调度程序。此过程会安排任务并定期将它们放入队列中。它不执行任务。

您需要开始celery beat 并且 celery worker（我猜您正在使用 django-celery）：

python manage.py celery beat
python manage.py celery worker

或者简单地说：

python manage.py celery worker --beat