Dask 错误：值的长度与索引的长度不匹配

Question

我已经通过这种方式使用dask 读取了 csv 文件：

import dask.dataframe  as dd
train = dd.read_csv('act_train.csv')

然后我想对每行应用简单的逻辑，这在 pandas 中工作得很好：

columns = list(train.columns)

for col in columns[1:]:
    train[col] = train[col].apply(lambda x: x if x == -1 else x.split(' ')[1])

不幸的是，最后一行代码产生了以下错误：Length of values does not match length of index

我做错了什么？

Answer 1

如果 x 不包含空格字符，则 x.split(' ') 将返回一个包含单个元素 x 的列表。

所以，当你试图通过调用访问 x.split(' ') 的第二个元素时 x.split('')[1]。它会给出错误：

“值的长度与索引的长度不匹配”，因为 x.split(' ') 中的索引 1 处没有元素。