Dask, как сводить DataFrame - PullRequest
Новая
       9

Dask, как сводить DataFrame

0 голосов
/ 14 октября 2018

Я использую приведенный ниже код, но получаю сообщение об ошибке после поворота фрейма данных:

фрейм данных: 

    name        day        value    time
0   MAC000002   2012-12-16  0.147   09:30:00
1   MAC000002   2012-12-16  0.110   10:00:00
2   MAC000002   2012-12-16  0.736   10:30:00
3   MAC000002   2012-12-16  0.404   11:00:00
4   MAC000003   2012-12-16  0.845   00:30:00

Чтение данных и поворот 

ddf = dd.read_csv('data.csv')
#I added this but didnt fix the error below
ddf.index.name = 'index'

#dask requires string as category type
ddf['name'] = ddf['name'].astype('category')
ddf['name'] =ddf['name'].cat.as_known()

#pivot the table
df = ddf.pivot_table(columns='name', values='value', index='index')
df.head()
#KeyError: 'index'

Ожидаемый результат (с индексом или без индекса) - поворот строк к столбцам без изменения значения: 

MAC000002  MAC000003  ...
0.147      0.845
0.110      ...
0.736      ...
0.404      ...

Есть идеи, почему я получаю KeyError 'index' и как мне это преодолеть?

...