有了这个我就明白了 ValueError :
import dask as dd
data1 = dd.read_sql_table('TABLE', connection_string, index_col = ['DATE','ITEM'],schema= 'CRE') gives me a value error --> ValueError: Use label when passing an SQLAlchemy instance as the index当我使用如下所示的日期时，我能够将数据拉入 dask dataframe .
data1 = dd.read_sql_table('TABLE', connection_string, index_col ='DATE',schema= 'CRE')
1条答案
按热度按时间vuv7lop31#
我猜dd.read\u sql\u表需要一个索引列来拆分数据。理想情况下，此列在sql数据库中建立索引，以便很容易进行分区/切分。
一旦将数据读入daskDataframe，就可以对其执行其他操作。但是，请注意，自2020年6月27日起，daskDataframe不支持多索引。