用Celery创建动态队列

用Celery创建动态队列

celery -A proj control add_consumer foo -d worker1.local

可以使用

app.control.add_consumer（）

方法动态地完成相同的 *** 作：

app.control.add_consumer('foo', reply=True)[{u'worker1.local': {u'ok': u"already consuming from u'foo'"}}]app.control.add_consumer('foo', reply=True,destination=['worker1@example.com'])