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=['[email protected]'])
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)