仪表板 "Column Assignment Doesn't Support Timestamp"

Dask "Column Assignment Doesn't Support Timestamp"

尝试将 pandas 日期时间添加到 Dask DataFrame,可重现的示例如下:

# library imports
import pandas as pd
from sklearn import datasets
from dask import dataframe as dd 

# Load toy data
iris = datasets.load_iris()
DF = pd.DataFrame(iris.data, columns = iris.feature_names)

# Convert Pands DataFrame to Dask DataFrame
ddf = dd.from_pandas(DF, npartitions = 2)

# Add a date column                                                                     
months_ago = 50
some_date = pd.datetime.today() - pd.DateOffset(months=train_months_back)

# Add state column to DataFrame
DF['date_vintage']= some_date # works fine
ddf['date_vintage']= some_date # TypeError: Column assignment doesn't support type Timestamp

TypeError: Column assignment doesn't support type Timestamp

我应该如何将 pandas 日期时间作为日期时间(不是字符串)列添加到 dask 数据框?我找到了一些关于将字符串转换为 dask 日期时间或日期时间索引的资源,但无法使其正常工作。在此先感谢您的帮助!

现在已在 dask 版本中实现 >= 0.17.1

df['timestamp'] = pd.Timestamp(...)