【分布式】通过Numpy创建Dask.array
生活随笔
收集整理的這篇文章主要介紹了
【分布式】通过Numpy创建Dask.array
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
【入門教程】
代碼如下:
import numpy as np import dask.array as da x = np.arange(10) y = da.from_array(x, chunks=(100, )) print(y.mean().compute())輸出的結果是:
4.5
代碼如下:
import numpy as np import dask.array as da x = np.arange(1000) y = da.from_array(x, chunks=(100, )) print(y.mean().compute())輸出的結果如下:
499.5
函數解釋:
da.from_array(array_like, chunks, *)
其實后面還有很多其他參數,但對于這樣的一篇入門文來說,其實就沒有必要了
- 第一個就是說,輸入的第一個參數是要有點像數組的東西。
- 重點要說下的是,這個array_like,必須要有個屬性是(.shape), 否則是不可使用的。
- chunks,可以是int,也可以是tuple,我覺得這個主要是為了增加使用的效果(因為以前遇到過這樣的bug,就是一定要用tuple,就算是數字也必須要使用(1,),這種表達式)
.compute() 這些就不說了(dask必用的幾個函數之一)
總結
以上是生活随笔為你收集整理的【分布式】通过Numpy创建Dask.array的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 【具体使用实例】Rall封装线程(C\C
- 下一篇: 某些列满足特定条件,然后改变另外的某些列