可以在 Dask web UI 中显示工人姓名吗？

Question

我可以将工作人员添加到 dask-scheduler 并且他们出现在网络中 ui，但是工作人员是按他们的 IP 地址列出的，而不是我给他们的名字。

当我创建工人时（在 Python 脚本中），我确实设置了名称：

import dask
import dask.dataframe as dd
from dask.distributed import Client as Dask_Client
from distributed import Worker

dask_client = Dask_Client('192.168.0.162:8786')
loop = IOLoop.current()
t = threading.Thread(target=loop.start, daemon=True)
t.start()
w = Worker('tcp://192.168.0.162:8786', loop=loop, name=socket.gethostname())
w.start()

当我运行 print(json.dumps(dask_client.scheduler_info(), sort_keys=True, indent=4)) 时，工人的名字确实出现了——摘录以下：

    "tcp://192.168.0.198:39619": {
        "host": "192.168.0.198",
        "id": "alana1",
        "last_seen": 1558707665.9223647,
        "local_directory": "[omitted]",
        "memory_limit": 8243511296,
        "metrics": {
            "cpu": 4.0,
            "executing": 0,
            "in_flight": 0,
            "in_memory": 330,
            "memory": 245129216,
            "num_fds": 26,
            "read_bytes": 3020.000227124918,
            "ready": 0,
            "time": 1558707665.9237077,
            "write_bytes": 3484.3077504469734
        },
        "name": "alana1",
        "ncores": 4,
        "resources": {},
        "services": {
            "bokeh": 37993,
            "nanny": 35817
        },
        "type": "Worker"

在上面的示例中，我希望名称 "alana1" 会出现在 Dask 网络中 UI 而不是出现的名称："tcp://192.168.0.198:39619"

Answer 1

是的。这可以通过更改 Dask 代码库来实现。

听起来您是在请求功能。我建议提出一个 github 问题。

可以在 Dask web UI 中显示工人姓名吗？

Possible to display worker names in Dask web UI?

python

dask

dask-distributed