Django Céleri avec RabbitMQ

Question

J'essaie d'exécuter la tâche avec Céleri. Je suis ces tutoriels link

Tout a été installé avec succès. La chose est maintenant que je ne sais pas comment exécuter une tâche. Je cours celeryd et il n'a pas pu trouver la tâche. Je veux savoir exactement ce que j'ai besoin d'appeler pour exécuter la tâche et comment j'ai besoin de configurer la tâche sur le serveur RabbitMQ, django-admin .. Je ne trouve pas de tutoriel complet à ce sujet.

Answer 1

Django by example a une section complète sur l'utilisation de céleri avec RabbitMQ. Il y a aussi des tutoriels gratuits ou des articles sur ce sujet

• How to install Celery on Django and Create a Periodic Task
• Django Celery Part 1
• Django Celery Part 2

Answer 2

définition de tâche app/tasks.py:

from celery import shared_task 

@shared_task 
def add(param1,param2) 
    print("task") 

exécution de la tâche:

from celery import current_app 
current_app.send_task("app.tasks.add", ["param1", "param2"]) 

Answer 3

Ceci pourrait vous aider à avoir une idée sur la façon de lancer Celery.

Cela a bien fonctionné pour moi.

http://www.hiddentao.com/archives/2012/01/27/processing-long-running-django-tasks-using-celery-rabbitmq-supervisord-monit/