django - celery celerybeat 不滴答作响

Question

我有以下设置:

celery-with-redis - 3.0        - active 
celery          - 3.0.12       - active 
django-celery   - 3.0.11       - active
django-kombu    - 0.9.4        - active
kombu           - 2.5.8        - active
redis           - 2.4.10

我的 celery 设置如下:

BROKER_URL = "redis://:password@localhost:6379/0"
REDIS_DB = 0
REDIS_CONNECT_RETRY = True
CELERY_SEND_EVENTS=True
CELERY_RESULT_BACKEND="redis://:password@localhost:6379/0"
CELERY_TASK_RESULT_EXPIRES =  10
CELERYBEAT_SCHEDULER="djcelery.schedulers.DatabaseScheduler"

检查我的 celerybeat 日志文件有以下内容

<ModelEntry: celery.backend_cleanup celery.backend_cleanup(*[], **{}) {<crontab: * 4 * * * (m/h/d/dM/MY)>}>
<ModelEntry: testing  spider.tasks.downloadCEA(*[], **{}) {<crontab: 4 9 * * * (m/h/d/dM/MY)>}>
[2013-04-02 09:16:15,364: DEBUG/MainProcess] Celerybeat: Ticking with max interval->5.00 seconds

但是，它并没有像日志文件中预期的那样唤醒和 sleep ，而且通过管理界面修改的任务更改也没有反射(reflect)在日志文件中。然而，当我重新启动 redis 时，适当的行为又回来了。

有人可以就此提出建议吗？

更新:我对我的 redis 进程进行了快速 top 检查 - 它消耗了 100% 的 cpu 使用率!有人吗？

Answer 1

抱歉，我要在这里回答我的问题。

事实证明我使用的是旧版本的 kombu，并且从 workers 创建了很多到 redis 的连接。将问题升级到更高版本解决了问题。

描述了这个问题 here通过@asksol。