监视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. 我注意到任务图、工作者或任务流(以及其他部分)的选项卡仍然是空的。在运行计算时，不应该显示某种进度吗？
2. ，这让我想知道，如何告诉xarray显式地使用这个集群？还是Client是一个单例，xarray无论如何都只有一个实例可以使用？

Answer 1

当您创建Dask客户端时，它会自动注册自己，作为运行Dask计算的默认方式。

您可以检查一个对象是否是带有dask.is_dask_collection函数的Dask集合。正如您所说，我相信xr.open_mfdataset默认使用Dask，但这将是一种很好的检查方法。

至于你为什么看不到仪表板上的任何东西，不幸的是，我对你的处境不太了解，无法在那里帮助你。