显示器dask-xarray的性能

Question

我有以下基本代码（我认为）应该将xarray设置为使用LocalCluster。

from dask.distributed import Client
client = Client("tcp://127.0.0.1:46573") # this points to a LocalCluster

import xarray as xr
ds = xr.open_mfdataset('*.nc', combine='by_coords') # Uses dask to defer actually loading data

我现在启动一些任务，该任务也可以顺利完成：

(ds.mean('time').mean('longitude')**10).compute()

1. 我注意到我的LocalCluster的dask-labextension中的Task图，Workers或Task流（以及其他）的选项卡保持空白。在运行计算时是否应该显示某种进度？

2. 这使我想知道，如何告诉xarray显式使用此集群？还是Client是一个单例，以至于xarray只能有一个实例要使用？

Answer 1

创建Dask Client时，它会自动注册为运行Dask计算的默认方式。

您可以使用dask.is_dask_collection功能检查对象是否为Dask集合。如您所说，我相信默认情况下xr.open_mfdataset使用Dask，但这是一种很好的检查方法。]

关于您为什么在仪表板上看不到任何东西，很遗憾，您对您的情况了解不足，无法在那里为您提供帮助。