开始使用免费开始使用

将使用哪种调度器?

在下面的代码块中,结果 wxyz 中,哪些会使用并行进程进行计算?

dask_df 是一个 Dask DataFrame,dask_bag 是一个 Dask bag。

w = dask_df.compute()

client = Client(processes=True)

x = dask_df.compute()

y = dask_df.compute(scheduler='threads')

z = dask_bag.compute()

本练习是课程的一部分

Python 中的 Dask 并行编程

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习