Comment utiliser la diffusion avec djcelery + ghettoq

Question

J'utilise djcelery 2.1.4 avec ghettoq 0.4.5 et django 1.2.3 et je suis capable d'exécuter des tâches toute la journée, mais quand j'essaie d'utiliser n'importe quelle diffusion fonctionnalité, il échoue sans erreurs. Prenez le cas le plus simple - je lance celeryd:

python manage.py celeryd 

Les départs démon et je tente de lancer un ping:

>>> from celery.task.control import ping 
>>> ping() 
[] 

Je peux voir le message qui apparaît ping créé dans la base de données, mais apparemment aucun des nœuds ne le ramasse? Est-ce que je fais quelque chose de mal ici? Est-ce que la diffusion ne fonctionne pas avec ghettoq?

Answer 1

La diffusion n'est pas prise en charge par ghettoq.

La prochaine version de Celery (2.2) supportera la diffusion pour Redis. Ajout de support pour la base de données devrait être simple alors.