Dask是一个灵活的并行计算库，用于分析计算。它支持针对计算和大数据集合优化的动态任务调度。
假设我有一个延迟的函数，可以执行某些任务，但是它需要一个字典来存储中间的键/值对，这些键/值对在每个dask worker中都可以读取和修改。可以延迟或其他...
我在S3中有一堆文件，这些文件包含一个大于内存的数据帧。当前，我使用Dask将文件读入数据帧，使用较小的数据集执行内部联接（这将改变...
向快速数据帧添加新列会引发ValueError：值的长度与索引的长度不匹配
我知道此追溯ValueError：值的长度与索引的长度不匹配是由于在ddf.assign（...
我一直在搜索，但是没有找到解决方案。我一直在研究Dask词典，但团队正在研究延迟的对象。我需要将dsk {}转换为上一步延迟的对象。 ...
dask.distributed.Client为什么在提供了已使用的已定义LocalCluster参数时引发“ TypeError：无法腌制'_thread.RLock'对象？”
通过使用dask.distributed.Client的空参数构造函数，我可以隐式创建dask.distributed.LocalCluster。但是，当我尝试使用...
我有7个csv文件，每个文件8 GB，需要转换为镶木地板。内存使用量达到100 GB，我不得不将其杀死。我也尝试了分布式Dask。内存限制为12 GB，但没有输出...
让Pandas DataFrame apply（）使用所有内核吗？
不幸的是，截至2017年8月，Pandas DataFame.apply（）仍仅限于使用单核，这意味着当您运行df时，多核计算机将浪费其大部分计算时间。
延迟延迟错误-AttributeError：'_ thread._local'对象没有属性'value'
我一直在绞尽脑汁想弄清楚为什么我无法在Dask上执行此可并行化的功能。本质上，我有一个在keras模型中加载的函数（我正在使用mlflow存储该模型）...
我正在尝试编写脚本以使用dask清理来自csvs的信息。我有一个从csv创建的daf df，如下所示：客户订单hashed_customer名字姓氏电子邮件...
我基于dask-docker Dockerfile创建了自己的略微修改的Dockerfile，该Dockerfile安装了adlfs并将我的自定义库之一复制到容器中，以使其对所有人可用...
更新我已将SSH密钥复制到我的所有计算机，并且它们能够在不使用密码的情况下进行通信，但是我仍然需要指定username @ hostname而不只是主机名。我...
是否可能有多个客户端？例如，我是否可以让多个线程同时每个线程运行一个客户端，以便当一个线程阻塞时，其他线程可以继续运行？在这种情况下，...
导入DASK时出错：模块'dask.array'没有属性'逐块'
我正在尝试使用DASK进行快速计算，因为逻辑回归在系统上运行17小时后中止。我的数据集大约有一百万行。我首先运行以下命令：将dask.array导入为da ...
我有一个大型CSV文件，它们以5毫米格网的小时分辨率表示美国的天气数据。每天都保存数据，因此我将它们串联在一起以获取年度文件。最终的...
为什么快扔IndexError：当我使用apply_along_axis时，索引1超出了大小为1的轴0的边界？
我尝试将dask.array.apply_along_axis用于2D数组。但是，我的数组是一个dask数组，它总是引发如下异常：Traceback（最近一次调用为last）：文件“ D：/ test / ...
读取HDF5作为Dask Dataframe时出错，为什么？
1。我的问题是，尝试使用Dask读取我的HDF5文件时出现下一个错误，我不知道为什么>>> dd.read_hdf（“ test.h5”，key =“ / RECORDS / STATES”）追溯（最近一次调用）最后）：...
我对Dask并不陌生，他试图构建一个系统来执行具有依赖关系的计算图。但是，有些任务虽然有一个...