我正在使用cx_Oracle
模块创建一个sqlalchemy
引擎,并使用Pandas从sqlalchemy
数据库中检索数据,但是性能方面存在问题,而且我正在获取数据库错误。
如果我只指定几个列,那么我的代码工作正常(但很慢),很长一段时间后,我可以得到所有的350万行。下面是我使用的代码:
import cx_Oracle
import pandas as pd
import config
from sqlalchemy import create_engine
engine = create_engine('oracle+cx_oracle://config.user:config.password@config.host:1521/?service_name=config.service')
sql = "select ITEM_NO, COUNTRY_CODE, LANGUAGE_CODE from table_ben_l_t where (LANGUAGE_CODE = 'es' and COUNTRY_CODE = 'ES')"
df = pd.read_sql(sql, engine)
一旦我添加了更多的列,我就不能再运行它了,因为经过很长时间的延迟(我说的是几个小时),我得到了一个数据库错误。
我知道使用这种方法检索数据和创建Pandas并不是唯一可用的方法,但是它绝对是最方便的.是否有更好/更安全的方法从Oracle DB获取这些数据?我想把这些行一片片地下载下来,把它们放到一个可以传递给Pandas的数据列表中,但是这看起来并不是很“优雅”.我相信一定有更好的方法.:-)
预先感谢任何能帮助我的人!
JF
编辑1:响应@OldProgrammer和@crocarneiro:
根据查询select * from all_ind_columns where table_name = 'TABLE_BEN_L_T';
的结果,没有对列的索引
编辑2: --这是我收到的错误消息:
DatabaseError: (cx_Oracle.DatabaseError) ORA-01555: snapshot too old: rollback segment number 509 with name "_SYSSMU509_3146905099$" too small
(Background on this error at: http://sqlalche.me/e/14/4xp6)
非常感谢@Christopher !这看起来很有趣!
发布于 2021-06-03 15:49:17
最后,我按照Christopher的建议,通过调优fetcharraysize
和prefetchrows
属性来解决这个问题。
我通过设置属性值显着地提高了性能,并且不再有超时和错误消息!
非常感谢所有帮助你的人!
JF
https://stackoverflow.com/questions/67778106
复制相似问题