Можно ли отображать имена рабочих в веб-интерфейсе Dask? - PullRequest
Новая
       10

Можно ли отображать имена рабочих в веб-интерфейсе Dask?

0 голосов
/ 25 мая 2019

Я могу добавить рабочих в dask-планировщик, и они появляются в веб-интерфейсе, но рабочие перечислены по их 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 вместо того, чтопоявляется: "tcp: //192.168.0.198: 39619"

1 Ответ

1 голос
/ 02 июня 2019

Да. Это возможно с изменениями в кодовой базе Dask.

Звучит так, будто вы запрашиваете функцию. Я рекомендую поднять проблему с github.

...