属性错误:模块“dask”没有属性“延迟”

She*_*rry 3 dask dask-delayed

使用Pycharm社区2018.1.4
Python 3.6
Dask 2.8.1

尝试在我的某些方法上实现 dask 延迟并收到错误

AttributeError: module 'dask' has no attribute 'delayed'.
Run Code Online (Sandbox Code Playgroud)

这显然不是真的,所以我想知道我做错了什么。我的实现结构如下:

AttributeError: module 'dask' has no attribute 'delayed'.
Run Code Online (Sandbox Code Playgroud)

本质上,我有一堆数据文件,它们是彼此独立的,所以我想并行运行它们,而不是通过 for 循环顺序运行,如果你取出 dask.delayed ,我就会这样做。
我是否从根本上错过了上述 dask 延迟实现中的任何内容?

Kow*_*a R 6

我参考以下网址https://github.com/dask/dask/issues/1849

要使用 pip 安装 Dask,有几个选项,具体取决于您想要保持最新的依赖项:

  • pip install dask[完整]:安装所有内容
  • pip install dask[array]:安装 dask 和 numpy
  • pip install dask[bag]:安装dask和cloudpickle
  • pip install dask[dataframe]:安装 dask、numpy 和 pandas
  • pip install dask:仅安装dask,仅依赖于标准库。如果您只需要任务计划程序,则这是合适的。