首页 > 解决方案 > 为什么 dask 返回子图而不是 read_csv().compute() 上的计算?

问题描述

当我这样做时dd.read_csv('AAPL.csv'),它会正确识别结构:

In [13]: dd.read_csv('AAPL.csv')
Out[13]:
Dask DataFrame Structure:
              2016-01-04T09:00:00Z   105.45 105.45.1    103.6  103.6.1    17462
npartitions=1
                            object  float64  float64  float64  float64  float64
                               ...      ...      ...      ...      ...      ...
Dask Name: read-csv, 1 tasks

但是当我尝试实际计算它时,它总是返回这个:

In [14]: dd.read_csv('AAPL.csv').compute()
Out[14]: 
0    (<Serialize: subgraph_callable-f9057ef2-07c7-4...
dtype: object

使用 pandas 导入时效果很好。我究竟做错了什么?

标签: dask

解决方案


推荐阅读