question débutant à RabbitMQ et Céleri

Question

J'ai commencé à jouer avec Céleri et RabbitMQ ce matin et défini des tâches de base pour voir comment la performance va améliorer mon serveur.

J'ai ajouté mes utilisateur rabbitmq, vhosts et mettre mes autorisations. Commencé mon serveur RabbitMQ

Dans un tutoriel très détaillé, j'ai trouvé ces gars-là utilisent celerybeat et celeryd pour voir l'état d'une tâche, et aussi de les exécuter.

le tutoriel détaillé par Rich Leland

Avez-vous le céleri aussi besoin d'une certaine manière, ou sont les mesures que j'ai pris assez?

Nulle part je ne ai vu aucune info ou des notes sur ce ... juste demander

Answer 1

Eh bien, vous aurez besoin d'avoir une sorte de processus de céleri en cours d'exécution pour les tâches de poignée dans la file d'attente. Le processus de celeryd écoute sur la file d'attente et exécute des tâches en fonction de vos paramètres. Si vous ne disposez pas d'un processus de celeryd course, vous aurez juste à ajouter des tâches à la file d'attente, mais jamais le vider.

Si vous êtes simplement intéressé à voir vos files d'attente, je vous recommande d'installer le plug-in de gestion RabbitMQ .

Answer 2

http://ask.github.com/celery/getting-started/ introduction.html

1. Démarrez votre serveur RabbitMQ
2. Définissez votre celeryconfig.py
3. Démarrez votre démon de céleri: celeryd

RabbitMQ a un login invité, donc c'est un moyen plus rapide pour commencer. Mettre cela en celeryconfig.py:

import sys
sys.path.append('.')

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

CELERY_RESULT_BACKEND = "amqp"

CELERY_IMPORTS = ("tasks",)

Pour un test rapide, mettre cela en tasks.py:

from celery.task import task

@task
def add(x, y):
    return x + y

if __name__ == "__main__":
    result = add.delay(4, 4)
    result.wait() 

Démarrer celeryd dans le même répertoire a celeryconfig.py et tasks.py:

celeryd --loglevel=INFO

Enfin, exécutez tasks.py