Dask，从几个 dask 数组创建一个数据框答案

【问题标题】：Dask, create a dataframe from several dask arraysDask，从几个 dask 数组创建一个数据框
【发布时间】：2017-08-20 21:41:33
【问题描述】：

假设我有一组 dask 数组，例如：

c1 = da.from_array(np.arange(100000, 190000), chunks=1000)
c2 = da.from_array(np.arange(200000, 290000), chunks=1000)
c3 = da.from_array(np.arange(300000, 390000), chunks=1000)

是否可以从它们创建一个 dask 数据框？在熊猫中我可以说：

data = {}
data['c1'] = c1
data['c2'] = c2
data['c3'] = c3

df = pd.DataFrame(data)

dask 有类似的方法吗？

【问题讨论】：

我怀疑您可以结合使用 dd.from_dask_array 和 dd.concat(..., axis=1)。

标签： python dask

【解决方案1】：

以下应该有效：

import pandas as pd, numpy as np 
import dask.array as da, dask.dataframe as dd

c1 = da.from_array(np.arange(100000, 190000), chunks=1000)
c2 = da.from_array(np.arange(200000, 290000), chunks=1000)
c3 = da.from_array(np.arange(300000, 390000), chunks=1000)

# generate dask dataframe
ddf = dd.concat([dd.from_dask_array(c) for c in [c1,c2,c3]], axis = 1) 
# name columns
ddf.columns = ['c1', 'c2', 'c3']

【讨论】：