如何获取运行芹菜工人的名称？

Question

我想特别关闭芹菜工人。我正在使用app.control.broadcast（'shutdown'）;但是，这将关闭所有工人；因此，我想传递目标参数。

当我运行PS -EF | GREP芹菜，我可以在该过程中看到- 主机名。

我知道该格式为{celeryd_nodes} {nodename_sep} {hostName} 来自实用程序函数 nodeName

destination =  ''.join(['celery', # CELERYD_NODES defined at /etc/default/newfies-celeryd
                        '@', # from celery.utils.__init__ import NODENAME_SEP
                         socket.gethostname()])

是否有返回nodeName的辅助功能？我不想自己创建它，因为我不想将值进行编码。

Answer 1

我不确定这是否是您要寻找的，但是使用

app = Celery('app_name', broker=...)
app.control.inspect().stats()  # statistics per worker
app.control.inspect().registered()  # registered tasks per each worker
app.control.inspect().active()  # active workers/tasks

​每个人的工人：

app.control.inspect().stats().keys()
app.control.inspect().registered().keys()
app.control.inspect().active().keys()

例如：

>>> app.control.inspect().registered().keys()
dict_keys(['worker1@my-host-name', 'worker2@my-host-name', ..])