问题:
pd.read_sql(sql的filename)出现异常
处理过程:
1.查看pandas.read_sql()源码

我传入的参数是sql语句的文件名,因此下一步执行的是else语句中的pandas_sql.read_query(),进入read_query()源码

从上图看,通过self.execute方法进行数据的获取。那么我们再进入execute源码。

先执行execute,若发生异常进行rollback回滚,若rollback回滚也产生异常,那么抛出DatabaseError,并且raise_with_traceback(ex)。
所以进行异常Exception捕获处理即可
其它
1.AnalysisException

该异常是spark端的
2.self.conn.connect是impyla.impala.dbapi

其连接实质是HiveServer2Connection

3.HiveServer2Connection.rollback

网友评论