使用芹菜3.1.25与Django 1.10
我可以通过手动进入shell并手动启动任务来获得芹菜来运行任务 . 但是,当我从django / admin / PeriodicTasks设置任务(每分钟运行一次)时,芹菜不会接收这些任务 .
我正在使用花来检查状态,但我没有看到任何失败的任务 .
代理节点被称为 celery@USER-vm
而不是 default
,因此我不知道这是否会影响这一点 .
我运行芹菜的命令是 python manage.py celery -A proj worker --loglevel=INFO -B
有什么见解的见解?我最好的猜测是djcelery没有连接到rabbitmq,但不确定在哪里进行这些更改 .
谢谢!
编辑:Settings.py
BROKER_URL="amqp://guest:guest@localhost//"
CELERY_BROKER_URL="amqp://guest:guest@localhost//"
CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler"
CELERY_SEND_TASK_ERROR_EMAILS=True
CELERYD_CONCURRENCY=8
CELERY_TASK_RESULT_EXPIRES=None
CELERY_ACCEPT_CONTENT = ['json', 'application','msgpack', 'yaml']
CELERY_DEFAULT_QUEUE='default'
CELERY_DEFAULT_EXCHANGE_TYPE='direct'
CELERY_DEFAULT_ROUTING_KEY='default'
CELERY_ENABLE_UTC=True
来自celery.py
from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE','proj.settings')
app = Celery('proj')
app.conf.update(
CELERY_TASK_RESULT_EXPIRES=3600,
)
app.autodiscover_tasks(settings.INSTALLED_APPS, related_name='tasks')