RabbitMQ/Apio con Django se cuelga en delay/ready/etc - No hay información de registro útil

Question

Así que configuré apio y rabbitmq, creé mi usuario, configuré el vhost, mapeé al usuario al vhost y ejecuté el daemon de apio con éxito (o por lo que supongo)

(queuetest)corky@corky-server:~/projects/queuetest$ ./manage.py celeryd 
celery@corky-server v0.9.5 is starting. 
Configuration -> 
. broker -> amqp://celery@localhost:5672/ 
. queues -> 
. celery -> exchange:celery (direct) binding:celery 
. concurrency -> 2 
. loader -> celery.loaders.djangoapp 
. logfile -> [stderr]@WARNING 
. events -> OFF 
. beat -> OFF 

Celery has started. 

he creado un usuario de "apio" porque no me sentía muy inventiva en este caso.

Cuando trato de hacer uno de los ejemplos sencillos dentro de los documentos de apio:

>>> from tasks import add 
>>> r = add.delay(2, 2) 
>>> r 
<AsyncResult: 16235ea3-c7d6-4cce-9387-5c6285312c7c> 
>>> r.ready() 
(hangs for eternity.) 

lo que he comprobado la AYUDA preguntándose qué otra cosa podría estar arriba y me dijeron que esto es un error común debido a los permisos de usuario , así que los compré tres veces, nada, hice otro usuario nuevo, todavía nada. Si importo DjangoBrokerConnection desde carrot.connection y obtengo la información, coincide con lo que hay en mi configuración de apio. Las preguntas frecuentes indicadas para verificar su archivo de registro.

Mi archivo rabbit.log no es muy útil en esta situación, simplemente mostrando:

=INFO REPORT==== 26-Jan-2010::11:58:22 === 
accepted TCP connection on 0.0.0.0:5672 from 127.0.0.1:60572 

=INFO REPORT==== 26-Jan-2010::11:58:22 === 
starting TCP connection <0.1120.0> from 127.0.0.1:60572 

Y así sucesivamente. En este punto, no sé qué otro problema podría tener. Estoy ejecutando Ubuntu Jaunty e instalé RabbitMQ en apt-get.

Gracias de antemano por cualquier ayuda.

Answer 1

Acabo de arreglar un error realmente feo que solo se mostraría a los usuarios nuevos que podrían haber causado esto. (http://github.com/ask/celery/commit/a9c1316b15055b67ee3c38d294461fa82ed6d2b5)

Por favor, extraiga de la rama principal en github. Si aún así no funciona, probable que tenga que dejar de RabbitMQ, eliminar el directorio de base de datos RabbitMQ (por lo general /var/lib/rabbitmq) y empezar de nuevo RabbitMQ)

Realmente lo siento por las molestias. El error ocurrió porque recientemente cambiamos el nombre de la opción de clave de enrutamiento de los consumidores a "clave de enlace", pero las bibliotecas amqp todavía usan routing_key y olvidamos volver a escribir la opción.

Answer 2

Para cualquier persona que se tropiece con esto: realmente parece ayudar a eliminar su/var/lib/rabbitmq, incluso si el problema parece desaparecer con la actualización del apio. Estaba viendo mucha falta de fiabilidad e imprevisibilidad hasta que lo hice.