如何让广播与 djcelery+ghettoq 一起使用
我将 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 一起使用吗？
I am using djcelery 2.1.4 with ghettoq 0.4.5 and django 1.2.3 and I am able to run tasks all day long, but when I try to use any broadcast functionality it fails without errors. Take the simplest case -- I run celeryd:
python manage.py celeryd
The daemon starts and I try to run a ping:
>>> from celery.task.control import ping
>>> ping()
[]
I can see the message that ping created appear in the database, but apparently none of the nodes are picking it up? Am I doing something wrong here? Does broadcast not work with ghettoq?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
ghettoq 不支持广播。
下一个 Celery 版本（2.2）将支持 Redis 的广播。添加对数据库的支持
那么应该很简单。
Broadcast is not supported by ghettoq.
The next Celery version (2.2) will support broadcast for Redis. Adding support for database
should be simple then.