芹菜任务不会执行

Question

我已关注instruction process to installing and setting up celery，现在我正在尝试执行我的任务。我的项目树如下所示：

bin
draft1--
        |
         -------draft1 ----
                           |
                            --------celery.py
                            --------tasks.py
                            --------views.py
         -------manage.py
         -------templates

include
lib

这是我的代码：

settings.py

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//' 

芹菜.py

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')

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

tasks.py

from celery import shared_task

@shared_task
def print_this():
    print('ONE MINUTE')

app.views

print_this.delay()

所以我的 celery 函数不起作用，它不执行打印语句。我想要做的是每分钟执行一次功能。知道问题出在哪里吗？

Answer 1

我认为您需要在开始实验之前阅读更多内容。 Celery 是一个分布式任务队列，这基本上意味着，它会轮询一个队列以查看是否有任何任务需要运行。如果有，它会运行任务。

关于您的设置，您似乎有一个任务运行器，但没有运行器需要轮询以检查是否有任何任务要运行的队列。配置CELERY_BROKER_URL 是关于该队列的。我建议您从阅读"Celery's Introduction documents" 开始。尤其是"What do I need?" 部分。

找出队列部分后的注意事项

另外，我不确定您如何运行和服务您的 django 应用程序，但 celery 需要单独的进程。对于这部分，您需要浏览"First Steps with Celery"。