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.d/celerdy start 启动 celeryd 时

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

[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)

我做错了什么？

-苏博德

Answer 1

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