Dask是一个灵活的并行计算库，用于分析计算。它支持针对计算和大数据集合优化的动态任务调度。
我来这里是因为我不明白我的问题。 我创建了一个 dockerfile + compose，它创建了 1 个 dask 调度程序和 2 个工作线程： docker-compose.yaml： 版本：'3.8' 服务： dask 调度程序...
如何使用普通 python（不是 ipython）查看或保存 <IPython.core.display.Image object>？
在学习dask的过程中，我尝试使用“visualize”方法/函数生成程序图可视化。但是，我不使用笔记本电脑。据我所知，我...
Xarray/Dask：map_block 计算 - 变量大小不一致
Python 代码的可行示例： 将 numpy 导入为 np 将 xarray 导入为 xr 从 scipy.optimize 导入 curve_fit 将 pandas 导入为 pd 将 xesmf 导入为 xe 从 dask.distributed 导入客户端 定义
使用dask数组时xarray.open_mfdataset(parallel=True)和xarray.concat有什么区别？
我正在使用Python处理经典的数据处理工作流程，即加载大量文件，预处理它们，连接它们并应用一些缩减。 目前，我正在使用...
AttributeError：导入 Dask 时模块“pandas.core.strings”没有属性“StringMethods”
即使 import dask 有效，我在尝试导入 dask.dataframe 接口时收到问题标题中所述的错误。 我当前的 dask 版本是 2022.7.0。可能是什么问题？
我正在使用 dask 和 zarr 来操作一些非常大的图像。 我设置了一个管道，可以对这些图像执行一些转换，然后我想测量图像的属性......
我正在使用 SLURM 集群，并且希望能够在我的任务中添加自定义日志，这些日志在检查特定工作人员时应显示在仪表板上的日志中。 或者我会...
Dask DataFrame - 根据分隔符将多个字符串列同时拆分为多行
我有一个大型 Dask DataFrame，看起来像这样： 铬 销售点 ID 参考文献 丙氨酸转氨酶 结果 Ensebl_geneid Ensembl_蛋白质ID Ensebl_transcriptid ETC 1 10000 1-10000-A-C A C 康11,康12,康13 ...
经过一番搜索，我未能找到 fastparquet 和 pyarrow 的彻底比较。 我找到了这篇博文（速度的基本比较）。 以及一个 github 讨论，声称文件创建...
我有多个 .csv.gz 文件，我正在尝试将其读入 dask 数据帧，我能够使用以下代码实现此目的： file_paths = glob.glob(file_pattern) @延迟 def read_csv(文件路径):
Dask 与简单的顺序应用程序：将无限数据写入单个 NetCDF
我需要将所有无限制（目前已增长 1TB）数据导出到单个 NetCDF4 文件。 完整的 ETL 包括： 各种计算 然后将所有结果写入单个 NetCDF 文件
我确信有一个简单的解决方案，但我有一个 python 函数，它在运行时打印一些值，但是，我也想使用 dask 运行它，但我不想打印t 的输出...
我正在尝试在dask数据帧中的groupby聚合下提取一系列的“模式”。我可以找到模式的文档，但找不到如何在分组下使用它。 导入熊猫...
我正在尝试将大型 dask 数据帧上传到 sql 服务器，但出现错误并且看不到连接字符串有任何问题。我可以使用此连接连接到数据库...
我正在尝试uproot的dask功能，即将分支加载到dask数组中。 不幸的是，我不明白为什么在尝试对这些执行计算时会发生事情
如果包含的 dask.distributed 任务失败，为什么完美任务不会失败？
我正在使用 DaskTaskRunner 使用 Prefect 运行工作流程，它创建并保存 dask.distibuted.LocalCluster 实例。 在完美的任务中，我使用 dask_ml.RandomSearchCV 并拟合它，这......
dask 的 read_parquet 读取加载模式时应过滤掉的文件
我遇到了一个问题，我正在保存具有稍微不同架构的不同镶木地板文件，但它们具有共享分区列。我创建了以下内容作为最小的可复制示例...
statsmodels 在其提供的任何机器学习模型中使用时是否与 Dask 数据框不兼容？
我正在尝试 statsmodels 将我的数据拟合到逻辑回归模型（Logit），但我拥有的数据框不是 pandas 数据框，而是 Dask 数据框。 这是我的示例数据集：smarket_1： 回应
Dask 对特定列上的数据进行分组和排序会返回空结果，因为块中的数据为空
我有一个数据集，其中包含 Id 以及句子中特定 Id 的开始和停止。这是一个庞大的数据集，约有 2.5 亿行。 现在我需要处理这些数据以将这些 Id 转换为序列...
我想在 Databricks 上使用 Dask。这应该是可能的（我不明白为什么不可以）。如果我导入它，会发生以下两种情况之一，要么我收到导入错误，但当我安装分布式来解决这个问题时