连接到AWS Athena时从pandas read_sql()方法捕获异常

2024-04-26 03:41:09 发布

您现在位置:Python中文网/ 问答频道 /正文

我有一个程序,我想让它更健壮。 它连接到雅典娜,然后将数据读入熊猫数据帧 使用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

Tags: 模块数据方法import程序dfreadsql