0

我在将宝藏数据中的查询结果加载到熊猫数据框时遇到了一些问题。到目前为止我尝试了什么：

import pytd.pandas_td as td
engine = td.create_engine('presto:dbname')

df = td.read_td(['SELECT * FROM shop_items'], engine, index_col='time', parse_dates=None)
---------------------------------------------------------------------------
TypeError                                 Traceback (most recent call last)
<ipython-input-85-d7c67d01919b> in <module>
----> 1 df = td.read_td(['SELECT * FROM shop_items'], engine, index_col='time', parse_dates=None)

D:\anaconda\lib\site-packages\pytd\pandas_td\__init__.py in read_td_query(query, engine, index_col, parse_dates, distributed_join, params)
    190 
    191     return _to_dataframe(
--> 192         engine.execute(header + query, **params), index_col, parse_dates
    193     )
    194 

TypeError: can only concatenate str (not "list") to str

我尝试过的另一件事是

df = td.read_td('SELECT * FROM shop_items', engine, index_col='time', parse_dates=None)

---------------------------------------------------------------------------
TypeError                                 Traceback (most recent call last)
<ipython-input-86-87be9bfcb398> in <module>
----> 1 df = td.read_td('SELECT * FROM shop_items', engine, index_col='time', parse_dates=None)

D:\anaconda\lib\site-packages\pytd\pandas_td\__init__.py in read_td_query(query, engine, index_col, parse_dates, distributed_join, params)
    190 
    191     return _to_dataframe(
--> 192         engine.execute(header + query, **params), index_col, parse_dates
    193     )
    194 

D:\anaconda\lib\site-packages\pytd\pandas_td\__init__.py in _to_dataframe(dic, index_col, parse_dates)
    326 
    327 def _to_dataframe(dic, index_col, parse_dates):
--> 328     frame = pd.DataFrame(**dic)
    329     if parse_dates is not None:
    330         frame = _parse_dates(frame, parse_dates)

TypeError: 'dict' object is not callable

我曾尝试使用“pytd.pandas_td Reference”，但重复列出的步骤没有成功。

4

0 回答 0