如何通过广播来使用djcelery+ghettoq

Question

我使用的是带有ghettoq 0.4.5和django 1.2.3的djcelery 2.1.4，我可以整天运行任务，但是当我尝试使用任何广播功能时，它都失败了，没有出现错误。举个最简单的例子--我运行celeryd：

python manage.py celeryd

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

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

我可以看到ping创建的消息出现在数据库中，但显然没有节点选择它？我是不是做错了什么？广播不能与ghettoq一起工作吗？

Answer 1

ghettoq不支持广播。

下一个版本(2.2)将支持Redis的广播。添加对数据库的支持应该很简单。