python - 如何将 Pandas future 列表转换为 Dask Dataframe？

Question

我有一个指向 Pandas 数据框的 Dask future 列表:

from dask.dataframe import Client
client = Client()

import pandas
futures = client.map(pd.read_csv, filenames)

如何将它们转换为 Dask 数据框？

注意，我知道 dask.dataframe.read_csv 存在，我只是以 pd.read_csv 为例

Answer 1

你可能想要 dask.dataframe.from_delayed

import dask.dataframe as dd
df = dd.from_delayed(futures)

有关其他选项，请参阅文档字符串。