为什么芹菜节拍不安排定期任务？

Question

我按照芹菜文档 https://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html 创建了一个应用程序和定期任务，如下所示：

$ tree demo/
demo/
├── config.py
├── __init__.py
└── tasks.py
$ cat demo/__init__.py 
# -*- coding: utf-8 -*-
from celery import Celery
app = Celery('demo')
app.config_from_object('demo.config')
$ cat demo/config.py 
# -*- coding: utf-8 -*-
BROKER_URL = "redis://127.0.0.1:6379"
CELERY_TIMEZONE='UTC'
CELERY_IMPORTS = [
"demo.tasks",
]
$ cat demo/tasks.py 
from demo import app
@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(3.0, say.s(), name='say hello every 3s')
@app.task
def say():
print("Hello!")

然后按如下方式运行芹菜节拍：

$ celery beat -A demo -l info --max-interval 10
celery beat v4.3.0 (rhubarb) is starting.
__    -    ... __   -        _
LocalTime -> 2019-12-12 16:26:41
Configuration ->
. broker -> redis://127.0.0.1:6379//
. loader -> celery.loaders.app.AppLoader
. scheduler -> celery.beat.PersistentScheduler
. db -> celerybeat-schedule
. logfile -> [stderr]@%INFO
. maxinterval -> 10.00 seconds (10.0s)
[2019-12-12 16:26:41,234: INFO/MainProcess] beat: Starting...

稍等片刻，没有任何任务计划。

但是，如果我更改为在配置中设置CELERYBEAT_SCHEDULE，它可以很好地工作。我通过更改demo/config.py和demo/tasks.py来做到这一点，如下所示：

$ cat demo/config.py 
# -*- coding: utf-8 -*-
from datetime import timedelta
BROKER_URL = "redis://127.0.0.1:6379"
CELERY_TIMEZONE='UTC'
CELERY_IMPORTS = [
"demo.tasks",
]
CELERYBEAT_SCHEDULE = {
'say hello every 10 seconds': {
'task': 'demo.tasks.say',
'schedule': timedelta(seconds=3),
},
}
$ cat demo/tasks.py 
from demo import app
@app.task
def say():
print("Hello!")

然后用和之前一样的命令运行芹菜节拍，周期性任务可以按预期每3秒调度一次。

我以前的设置有什么问题？

Answer 1

仅供参考，我想出了另一种解决方案，将装饰器@app.on_after_configure.connect更改为@app.on_after_finalize.connect可以使其工作。虽然此刻我不知道确切的原因。

Answer 2

Celery4.x 不使用大写配置变量 - 请参阅 Celery 文档的新小写设置部分。此处列出了特定于调度程序的配置参数。因此，请尝试修改您的代码以具有beat_schedule = {而不是CELERYBEAT_SCHEDULE = {。您说您关注的链接也使用小写名称...

Answer 3

您必须根据本用户指南通过--scheduler键指定调度程序。例如，您可以尝试以下代码：

celery beat -A demo -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler

附言我不确定--max-interval不会干扰您的日程安排。认为最好删除此选项。恕我直言。