我已经使用 dask read_sql_table 从 oracle 数据库成功引入了一张表。但是,当我尝试引入另一个表时,我收到此错误KeyError: 'Only a column name can be used for the key in a dtype mappings argument.'
我检查了我的连接字符串和架构,所有这些都很好。我知道表名存在,我试图用作索引的列是 oracle 数据库中表的主键。
有人可以解释为什么当列名明确存在时会发生此错误吗?
我知道我可以使用 Pandas 块,但在这种情况下宁愿使用 dask。
下面是我如何连接到 oracle 数据库和错误消息的最后一点
host='*******'
port='*****'
sid='****'
user='******'
password='*****'
con_string = 'oracle://' + user + ':' + password + '@' + host + ':' + port + '/' + sid
engine = create_engine(con_string)
df =ddf.read_sql_table('table_name', uri=con_string, index_col='id', npartitions=None, schema='*****')
Run Code Online (Sandbox Code Playgroud)
~\AppData\Local\Continuum\anaconda3\lib\site-packages\pandas\core\generic.py in astype(self, dtype, copy, errors, **kwargs) 5855
如果 col_name 不在 self: …