python - 连接到 AWS Athena 时从 pandas read_sql() 方法捕获异常
问题描述
我有一个程序,我想让它更健壮。它连接到 Athena,然后使用 read_sql() 方法将数据读入 pandas 数据帧。如果查询出现问题并且一般 Exception 不起作用(请参见下文),我找不到捕获异常的正确方法。我知道我应该导入 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
解决方案
推荐阅读
- c++ - 引用父或子的向量
- node.js - 导入 CSV 日期字段时,Kuzzle 使用映射创建索引
- arangodb - ArangoDB 将整个 Graph 导出为 JSON
- r-markdown - 如果文件是指向相对路径的符号链接并且链接的名称与文件不同,则使用 rmarkdown::render 进行编译不起作用
- node.js - 收到错误无法读取未定义的属性“readIntBE”
- python - 合并大型 h5 数据集
- hbase - HBase 或 Azure 日志分析
- c++ - 错误:std::thread 参数在转换为右值后必须是可调用的
- ios - 如何构建一个基于行状态不同的 iOS 可滑动 UIContextualAction
- c# - 仅使用 .Net 生成证书请求并提交给 CA