对象是否dask.delayed
由集群上的 dask 分发?
另外,它的任务图的执行是否也分布在集群上?
简短的回答是肯定的。
用户通过将本地 Python 会话连接到调度程序并提交工作进行交互,或者通过单独调用简单接口 client.submit(function, *args, **kwargs) 或使用父 dask 的大型数据集合和并行算法图书馆。dask 库中的集合(如 dask.array 和 dask.dataframe)提供了对复杂算法和熟悉的 API(如 NumPy 和 Pandas)的轻松访问,而简单的 client.submit 接口为用户提供了自定义控制,当他们想要突破罐头“大数据”抽象并提交完全自定义的工作负载。
Dask 延迟对象包含在“父 dask 库的并行算法”中。
有关更多信息,请参阅文档。 http://distributed.dask.org/en/latest/