在python3上安装/使用dask.array

Question

我正在测试dask模块（https://github.com/ContinuumIO/dask）以处理大数据数组，但无法使其工作到目前为止。乍一看，在我看来，与某些保留名称或类似的东西有冲突。

安装是在ubuntu上用$ pip3 install dask进行的，在Python 3.4.0上对IPython 1.2.1进行了测试。

我附上了一个最小的非工作示例。

任何想法？

谢谢！

In [1]: import numpy as np 
In [2]: import dask.array as da 
In [3]: x=da.random.normal(10,0.1,size=(10000,10000),chunks=(1000,1000)) 
In [4]: type(x) 
Out[4]: toolz.functoolz.curry 
In [5]: x.dask 
--------------------------------------------------------------------------- 
AttributeError       Traceback (most recent call last) 
<ipython-input-5-7982e592385b> in <module>() 
----> 1 x.dask 

AttributeError: 'curry' object has no attribute 'dask' 

Answer 1

这工作

In [1]: import numpy as np 
In [2]: import dask.array as da 
In [3]: x = da.random.normal(10, 0.1, size=(10000, 10000), chunks=(1000, 1000)) 
In [4]: type(x) 
Out[4]: dask.array.core.Array 

In [5]: import dask 
In [6]: dask.__version__ 
Out[6]: '0.6.0'