python - Dask:使用典型的 numpy 索引更新 dask 数组中的值时出现赋值错误

Question

我正在将代码转换为使用 dask 数组而不是 numpy 数组。

我安装了 dask 版本 0.19.4。

我有一个数组已被替换为等效的 dask 数组:

# this used to be a numpy array, created like so:
# da = np.zeros((total_months,))
da = dask.array.zeros((total_months,), chunks=(-1))

当我点击以下代码行(以前当​​数组是 numpy 数组时有效)时，我收到一个项目分配错误:

for k in range(total_months):
    da[k] = awc - s0

NotImplementedError: Item assignment with <class 'int'> not supported

awc 和 s0 都是上面的浮点标量。

我的理解是，正常的 numpy 样式切片和数组元素索引在 dask 中可以按预期工作，但这里没有发生这种情况。我可能在哪里误入歧途？

Answer 1

正确。不支持使用整数进行项目分配。

通常，使用 for 循环迭代大型数组的工作流程是不可扩展的。 Dask 阵列没有尝试支持它们。