假設(shè)我有以下數(shù)組：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然后我想將其轉(zhuǎn)換為延遲的 dask 數(shù)組：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))]]現(xiàn)在我想獲得一個(gè)特定的塊：chunk = da.from_delayed(data[1], shape=(3,2))print(chunk.compute())但是，我收到以下錯(cuò)誤：dsk = {(name,) + (0,) * len(shape): value.key}AttributeError: 'numpy.ndarray' object has no attribute 'key'我究竟做錯(cuò)了什么？
1 回答
慕桂英3389331
TA貢獻(xiàn)2036條經(jīng)驗(yàn) 獲得超8個(gè)贊
dask.array.Array.to_delayed()返回二維數(shù)組的列表列表。您需要一直切片到延遲對(duì)象才能將其傳遞給 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]])
添加回答
舉報(bào)
0/150
提交
取消