集群与客户端
根据您的计算机硬件和要完成的计算类型,混合使用线程和进程运行可能更快。为此,您需要设置一个本地集群。
设置 Dask 将使用的本地集群有两种方式。第一种方式是先创建本地集群,然后将其传递给客户端。这与在多台计算机组成的集群上设置客户端的方式非常相似!第二种方式是直接使用客户端,并让它自行创建本地集群。这是一个仅适用于本地集群的快捷方式,其他类型的集群不适用。
在本练习中,您将用这两种方法创建客户端。
创建集群和客户端时请务必小心。如果配置不正确,您的会话可能会超时。
本练习是课程的一部分
Python 中的 Dask 并行编程
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Import Client and LocalCluster
from ____ import ____, ____
# Create a thread-based local cluster
cluster = LocalCluster(
processes=____,
n_workers=____,
threads_per_worker=____,
)
# Create a client
client = ____