Dask“列分配不支持时间戳”

Question

尝试将 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：列分配不支持类型时间戳

我应该如何将 pandas 日期时间作为日期时间（而不是字符串）列添加到 dask 数据框中？我找到了一些关于将字符串转换为 dask 日期时间或日期时间索引的资源，但无法使其正常工作。提前感谢您的帮助！

Answer 1

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

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