Dask получает ошибку при преобразовании столбца timestamp в datetime

Question

У меня есть фрейм данных dask с этой структурой:

Dask DataFrame Structure:
               timestamp      bid    offer     high      low mid_open   change change_pct market_delay market_state update_time
npartitions=76                                                                                                                 
                 float64  float64  float64  float64  float64  float64  float64    float64       object       object      object
                     
Dask Name: read-csv, 76 tasks

Когда я пытаюсь добавить новый столбец с именем ds, который использует временную метку:

import pytz

tz = pytz.timezone('Europe/London')

kk['ds'] = datetime.datetime.fromtimestamp(float(kk.timestamp), tz)

, я получаю сообщение об ошибке:

TypeError: Series.__float__ returned non-float (type function)

Answer 1

Является ли kk объектом dask? Если это так, то это неверный номер, и float не будет знать, что с ним делать.

Я подозреваю, что вместо этого вы можете использовать метод .apply для применения обычного Python действует во всех строках вашей серии.