dask - 本地 Dask 工作人员无法连接到本地调度程序

Question

在 OSX 10.12.6 上运行 Dask 0.16.0 时，我无法将本地连接dask-worker到本地dask-scheduler。我只是想遵循官方Dask 教程。重现步骤：

第 1 步：运行dask-scheduler

第 2 步：运行dask-worker 10.160.39.103:8786

问题似乎与 dask 调度程序有关，而不是工作人员，因为我什至无法通过其他方式（例如，nc -zv 10.160.39.103 8786）访问端口。

但是，该过程显然仍在机器上运行：

score 5 · Accepted Answer

我的第一个猜测是，由于网络规则，您的计算机可能不接受看起来像是来自外部世界的网络连接。您可能想尝试使用dask-worker localhost:8786并查看它是否有效。

另外，提醒一下，您始终可以直接从 Python 启动调度程序和工作程序，而无需创建 dask-scheduler 和 dask-worker 进程

from dask.distributed import Client
# client = Client('scheduler-address:8786')
client = Client()  # create scheduler and worker automatically

作为一种万无一失的方法，您也可以通过processes=False这将完全避免网络问题

client = Client(processes=False)

1 回答 1