我有一个程序,我想让它更健壮。 它连接到雅典娜,然后将数据读入熊猫数据帧 使用read_sql()方法。 如果查询出了问题,而常规异常无法完成工作,我无法找到捕获异常的正确方法(请参见下文)。 我知道我应该导入Athena异常模块,但找不到如何导入。 我可以捕捉任何类型的Athena异常,包括sql语法、db对象问题、数据不一致等等 这是我的程序代码
import pyathena
import pandas as pd
try:
conn = pyathena.connect('hiding details...')
sql = 'select * from tbl'
df = pd.read_sql(sql, conn)
print(df)
except Exception as ex:
do some actions
目前没有回答
相关问题 更多 >
编程相关推荐