La tâche de céleri ne s'exécute pas

Question

J'ai suivi le instruction process to installing and setting up celery, maintenant j'essaye d'exécuter ma tâche. Mon arbre ressemble projet ceci:

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

include 
lib 

Voici mon code:

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

app.views

print_this.delay() 

donc ma fonction de céleri ne fonctionne pas, il n'exécute pas l'instruction d'impression. Ce que je veux faire est d'exécuter la fonction chaque minute. Une idée du problème?

Answer 1

Je pense que vous devez lire plus avant de commencer à expérimenter. Le céleri est une file d'attente de tâches distribuées, ce qui signifie essentiellement qu'il interroge une file d'attente pour voir si une tâche doit être exécutée. Si c'est le cas, il exécute la tâche. À propos de votre installation, vous semblez avoir un programme d'exécution de tâches, mais pas la file d'attente que le programme d'exécution doit interroger pour vérifier s'il y a des tâches à exécuter. La configuration CELERY_BROKER_URL concerne cette file d'attente. Je vous suggère de commencer par lire "Celery's Introduction documents". Surtout "What do I need?" partie.

NOTE POUR APRÈS comprendre Je ne sais pas comment vous exécutez LA QUEUE PARTIE

En outre, et servir votre application django, mais le céleri exige des processus séparés. Pour cette partie, vous devrez parcourir "First Steps with Celery".