假設我有以下數組：import numpy as npimport dask.array as daimport daskarr_x = list(range(0,100))arr_y = list(range(0,100))arr = np.stack([arr_x,arr_y])arr = arr.T然后我想將其轉換為延遲的 dask 數組：arr = da.from_array(arr,chunks = (3,2))data = arr.to_delayed()其格式如下：[[Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 0, 0))] [Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 1, 0))] [Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 2, 0))]... [Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 31, 0))] [Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 32, 0))] [Delayed(('array-fa3499f6a402676a68a198bef8016ec4', 33, 0))]]現在我想獲得一個特定的塊：chunk = da.from_delayed(data[1], shape=(3,2))print(chunk.compute())但是，我收到以下錯誤：dsk = {(name,) + (0,) * len(shape): value.key}AttributeError: 'numpy.ndarray' object has no attribute 'key'我究竟做錯了什么？
1 回答
慕桂英3389331
TA貢獻2036條經驗 獲得超8個贊
dask.array.Array.to_delayed()返回二維數組的列表列表。您需要一直切片到延遲對象才能將其傳遞給 from_delayed()
In [5]: chunk = da.from_delayed(data[1][0], shape=(3,2), dtype=arr.dtype) In [6]: chunk.compute() Out[6]: array([[3, 3], [4, 4], [5, 5]])
這也可以寫成
In [11]: arr.blocks[1, 0].compute() Out[11]: array([[3, 3], [4, 4], [5, 5]])
添加回答
舉報
0/150
提交
取消