python3上dask.array的安装/使用

Question

我正在测试 dask 模块 (https://github.com/ContinuumIO/dask) 以使用大数据数组，但目前无法使其工作。乍一看，在我看来，与某些保留名称或类似名称存在冲突。

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

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

有什么想法吗？

谢谢！！

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'