セロリのタスクは実行されません

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//' 

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

tasks.py

from celery import shared_task 

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

マイプロジェクトツリーは次のようになります

だから私のセロリの機能が動作しない、それはprint文を実行しません

print_this.delay() 

をapp.views。私がしたいことは毎分機能を実行することです。何が問題なのか？

Answer 1

実験を開始する前に、もっと読む必要があると思います。 Celeryは分散タスクキューです。基本的にはキューをポーリングして、実行する必要があるタスクがあるかどうかを確認します。存在する場合、タスクを実行します。

セットアップについては、タスクランナーがあるようですが、実行するタスクがあるかどうかを確認するためにランナーがポーリングする必要があるキューはありません。設定CELERY_BROKER_URLはそのキューに関するものです。私はあなたが"Celery's Introduction documents"を読むことから始めることをお勧めします。特に"What do I need?"部分。

NOTEキュー・PART

をOUT図の後にも、私はどのようにDjangoアプリケーションを実行して、仕えるかわからないけど、セロリは、別のプロセスが必要です。その部分のためにあなたはスキムを"First Steps with Celery"する必要があります。