好的,我已经正确安装了所有东西,以便在 django 中获得 celery + redis
我有
INSTALLED_APPS = (
'djcelery',
'kombu.transport.django',
)
这些在我的设置中
CELERY_REDIS_HOST = 'localhost'
CELERY_REDIS_PORT = 8889
CELERY_REDIS_DB = 0
CELERY_RESULT_BACKEND = 'redis'
BROKER_URL = "redis://localhost:8889/0"
REDIS_CONNECT_RETRY = True
CELERY_IGNORE_RESULT = True
CELERY_SEND_EVENTS = True
CELERY_TASK_RESULT_EXPIRES = 60
CELERYBEAT_SCHEDULER= 'djcelery.schedulers.DatabaseScheduler'
我让 redis 使用
./redis-server
它每秒输出到终端,所以我也可以运行
./manage.py celeryd -E -B --loglevel=INFO -n w1.d820
没有错误,我什至可以看到我的任务被添加并成功完成
./manage celeryev
所以即使认为它被 celeryev 记录了,这段代码也不起作用:
from celery.task import task
@task
def add(x, y):
return x + y
res = add.apply_async(args=[1,5])
print res.wait()
它只是挂起而没有返回结果,我可以看到它实际上试图从 redis 获取它,因为如果我这样做了
./redis-cli
MONITOR
我有很多 GET 试图获取不存在的密钥所以我的结论是 django 没有保存到后端我的设置有什么问题?我认为我错过了一些明显的东西,我看不到它,因为我与这个斗争太久了。帮助
顺便说一句,我不能使用标准端口 6379,因为我在共享服务器上。
使用这些更新
celery==2.5.3
django-celery==2.5.5
django-celery-with-redis==2.5