Таким образом, я просто устанавливаю сельдерей и rabbitmq, создал моего пользователя, установите vhost, отобразил пользователя на vhost и выполнил демона сельдерея успешно (или таким образом, я принимаю),
(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.
Я создал пользователя "сельдерея", потому что я не чувствовал себя очень изобретательным в этом случае.
Когда я пытаюсь сделать один из простых примеров в рамках документов сельдерея:
>>> from tasks import add
>>> r = add.delay(2, 2)
>>> r
<AsyncResult: 16235ea3-c7d6-4cce-9387-5c6285312c7c>
>>> r.ready()
(hangs for eternity.)
Таким образом, я проверил FAQ, задающийся вопросом, что еще могло произойти, и он сказал мне, что это - общая ошибка из-за полномочий пользователя, таким образом, я трижды проверил, что они, ничто, сделали другого нового пользователя, тем не менее ничто. Если я импортирую DjangoBrokerConnection
от carrot.connection
и получите информацию, она совпадает с тем, что находится в моих настройках сельдерея. FAQ, указанный для проверки файла журнала.
Мой rabbit.log
файл не очень полезен в этой ситуации, просто показывая:
=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
И т.д. На данном этапе я в замешательстве относительно того, чем еще могла быть моя проблема. Я запускаю Ubuntu, которую получают Бойкие и установленные RabbitMQ из Кв.-.
Заранее спасибо за любую справку.
Я только что зафиксировал действительно уродливую ошибку, которая будет отображаться только для новых пользователей, которые могли бы это вызвать. ( http://github.com/ask/celeary/commit/a9c1316b15055b67ee3c38d294461fa82ed6d2b5 ) ) ) ) ) )
Пожалуйста, потяните из главной ветви в GitHub. Если он все еще не работает
Вероятно, приходится остановить rabritmq, удалите каталог базы данных rabbitmq (обычно / var / lib / rabbitmq
) и начните rabritmq снова)
Очень жаль за неудобства.
Обижаемая ошибка, потому что мы недавно изменили имя ключа маршрутизации потребителей на «Ключ связывания», но библиотеки AMQP все еще используют Routing_key
, и мы забыли переписать опцию.