Celeryd坚持在配置为使用redis时检查amqp

Question

我正在尝试在我的设置中运行celerdy + redis。

CELERYD_NODES="worker1"
CELERYD_NODES="worker1 worker2 worker3"
CELERY_BIN="/home/snijsure/.virtualenvs/mtest/bin/celery"
CELERYD_CHDIR="/home/snijsure/work/mytest/"
CELERYD_OPTS="--time-limit=300 --concurrency=8"
CELERYD_LOG_FILE="/var/log/celery/%N.log"
CELERYD_PID_FILE="/var/run/celery/%N.pid"
CELERYD_USER="celery"
CELERYD_GROUP="celery"
CELERY_CREATE_DIRS=1
export DJANGO_SETTINGS_MODULE="analytics.settings.local"

base.py

BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
BROKER_HOST = "localhost"
BROKER_BACKEND="redis"
REDIS_PORT=6379
REDIS_HOST = "localhost"
BROKER_USER = ""
BROKER_PASSWORD =""
BROKER_VHOST = "0"
REDIS_DB = 0
REDIS_CONNECT_RETRY = True
CELERY_SEND_EVENTS=True
CELERY_RESULT_BACKEND='redis'
CELERY_TASK_RESULT_EXPIRES =  10
CELERYBEAT_SCHEDULER="djcelery.schedulers.DatabaseScheduler"
CELERY_ALWAYS_EAGER = False
import djcelery
djcelery.setup_loader()

但是，当我使用/etc/init. exe启动celeryd时d/celerdy开始

我在日志文件中看到以下消息

[2014-08-14 23:16:41,430: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111] Connection refused.
Trying again in 32.00 seconds...

它似乎在尝试连接amqp。有什么想法吗?我已经遵循了这里列出的程序

http://celery.readthedocs.org/en/latest/getting-started/brokers/redis.html我正在运行版本3.1.13 (Cipater)

我做错了什么?

subodh

Answer 1

如何开始你的芹菜工人?我遇到过一次这个错误，因为我没有正确启动它。您应该在执行"celery worker"时添加-A选项，以便芹菜连接到您在芹菜对象中配置的代理。否则，芹菜将尝试连接默认代理。

Answer 2

你的/etc/default/celeryd文件看起来不错。

您正在使用dj芹菜，然而。我建议你放弃那件事。如果你看一下Django安装指南和示例项目，你会注意到芹菜不再需要任何INSTALLED_APPS。现在，只有当你想使用Django SQL数据库作为后端时，才推荐使用dj芹菜。

• https://github.com/celery/celery/tree/3.1/examples/django/
• http://celery.readthedocs.org/en/latest/django/first-steps-with-django.html using-celery-with-django

我刚刚对这种模式进行了重建，我可以确认它工作正常，至少在连接到Redis而不是试图使用RabbitMQ (amqp)方面。