python - celery 任务不会执行

Question

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

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

include
lib

这是我的代码:

设置.py

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

celery .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()

任务.py

from celery import shared_task

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

应用 View

print_this.delay()

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

Answer 1

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

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

在弄清楚队列部分后的注意事项

此外，我不确定您如何运行和提供 django 应用程序，但 celery 需要单独的进程。对于那部分，您需要略读 "First Steps with Celery" .