Django celery无法将自定义调度程序设置为DatabaseScheduler

问题描述

我有一个Django项目设置并正在工作。芹菜也在工作，我不仅可以开始做工人，还可以做芹菜节拍。

尝试使用django_celery_beat并将自定义调度程序类设置为设置文件中的 django_celery_beat.schedulers：DatabaseScheduler 。但它仍使用默认的 PersistentScheduler。

settings.py

# Other settings
# Celery
CELERY_broKER_URL = 'redis://localhost:6379/0'
CELERY_CELERYBEAT_SCHEDULER = "django_celery_beat.schedulers:DatabaseScheduler"
CELERY_RESULT_BACKEND = 'django-db'

celery.py

from __future__ import absolute_import,unicode_literals
import os

from celery import Celery
from celery.schedules import crontab

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE','myproject.settings')

app = Celery('myproject')

app.config_from_object('django.conf:settings',namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

# my tasks imported here

但是，当我在这样的命令行中设置自定义计划程序时

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

然后一切都会按预期进行。

简而言之，我想在django settings.py中设置celery的自定义调度程序，这样我就不需要在命令行中指定所有内容。

更新： 如果我更改设置中的broker_url，则更改会很好地反映出来。因此，配置设置没有错。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）