如何更改 dask 调度程序和工作人员？答案

【问题标题】：How to change the dask scheduler and workers?如何更改 dask 调度程序和工作人员？
【发布时间】：2019-04-22 16:07:31
【问题描述】：

我是 dask 和分布式的新手。我想更改 dask 调度程序而不是 localhost 以使用服务器的另一个地址。我在互联网上没有找到如何做到这一点。

你能帮帮我吗？

谢谢。

【问题讨论】：

【解决方案1】：

我想您可以将服务器的 IP 传递给工作构造函数，就像在文档 http://docs.dask.org/en/latest/setup/python-advanced.html?highlight=scheduler#worker 中所做的那样

w = Worker('tcp://{your_ip_here}:8786')

【讨论】：

【解决方案2】：

从用户会话的角度来看，您使用客户端连接到远程 Dask 调度程序：

client = dask.distributed.Client('tcp://machine.ip:port')

这里需要酌情填写机器的地址和端口。你不应该在你的会话中构建一个 Worker，我假设你的调度器已经设置了一些可以与之交谈的 Worker。

是的，还有一些方法可以在配置文件中包含默认地址，包括让调度程序在启动时为您编写它，但您提到的 XML 文件不太可能是 Dask 直接读取的内容。另一方面，设计你的系统的人可能有自己的配置层。

【讨论】：