dask - 如何从命令行运行 dask 分布式本地集群？

Question

我想Client(LocalCluster())从命令行做相当于。

当与从 Jupyter 笔记本分发的分布式交互时，我最终会经常重新启动我的内核并LocalCluster每次都启动一个新内核，以及刷新我的散景网页。

我宁愿在后台运行一个可以连接到的进程，这可能吗？

Answer 1

这里的相关文档页面是http://distributed.readthedocs.io/en/latest/setup.html#using-the-command-line

在一个终端中，编写以下内容：

$ dask-scheduler

在另一个终端中，编写以下内容：

$ dask-worker localhost:8786

这里的默认值有点不同。LocalCluster 创建 N 个单线程工作者，而 dask-worker 启动一个 N 线程工作者。您可以使用以下关键字更改这些默认值

$ dask-worker localhost:8786 --nthreads 1 --nprocs 4