django - 如何让广播与 djcelery+ghettoq 一起使用

Question

我将 djcelery 2.1.4 与 ghettoq 0.4.5 和 django 1.2.3 一起使用，我能够整天运行任务，但是当我尝试使用任何广播功能时，它会失败而没有错误。以最简单的情况为例——我运行 celeryd：

python manage.py celeryd

守护进程启动，我尝试运行 ping：

>>> from celery.task.control import ping
>>> ping()
[]

我可以看到 ping 创建的消息出现在数据库中，但显然没有节点接收它？我在这里做错了吗？广播不适用于ghettoq吗？

Answer 1

ghettoq 不支持广播。

下一个 Celery 版本（2.2）将支持 Redis 广播。那么添加对数据库的支持应该很简单。