芹菜任务不起作用

Question

Celery

文档说 Celery 3.1 可以开箱即用地使用 django。但是任务不起作用。我有 tasks.py：

from celery import task
from datetime import timedelta
@task.periodic_task(run_every=timedelta(seconds=20), ignore_result=True)
    def disable_not_confirmed_users():
        print "start"

配置：

from kombu import Exchange, Queue
CELERY_SEND_TASK_ERROR_EMAILS = True
BROKER_URL = 'amqp://guest@localhost//'
CELERY_DEFAULT_QUEUE = 'project-queue'
CELERY_DEFAULT_EXCHANGE = 'project-queue'
CELERY_DEFAULT_ROUTING_KEY = 'project-queue'
CELERY_QUEUES = (
    Queue('project-queue', Exchange('project-queue'), routing_key='project-queue'),
)

项目/芹菜.py 从未来的进口absolute_import

import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
from django.conf import settings

app = Celery('project')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

润芹菜：celery -A project worker --loglevel=INFO

但什么都没有发生。

Answer 1

你应该使用芹菜节拍来运行定期任务。

celery -A project worker --loglevel=INFO

启动执行实际工作的工作线程。

celery -A proj beat

启动 Beat 服务，该服务要求工作完成作业。