python - 对 dask 数据帧进行分区并将其转换为 pandas 数据帧的最佳方法是什么？

Question

对 dask 数据帧进行分区并将其转换为 pandas 数据帧的最佳方法是什么？以下代码似乎永远挂起。

partitions = auc_ddf.to_delayed()
df = partitions[0]
df.head().compute()

标签： pythonpandasdask

Answer 1

你要

auc_ddf.partitions[i].compute()

i你想要的零件的编号在哪里。请注意，这些部分已经是 pandas 数据帧，因此如果您的目的是以某种方式处理它们，那么您可能根本不需要这样做。