我试图捕捉任何错误,当我通过气流中的Python运算符在Bigquery中运行查询时。但我无法获得预期的行为。它不会抛出任何异常。
这就是我所尝试的。
from google.cloud import bigquery
client = bigquery.Client(project='project_id')
query = "select 1 as cnt from gudb.TEST001 limit 1"
try:
client.query(query)
except Exception as e:
print(e)
它不会抛出任何异常,即使表在bigquery中不可用。但当我试图存储变量时
var=client.query(query) # in try
for x in var:
print(x)
我可以看到存储在该var中的异常。但是我希望在运行tryexcept块时在stdout中提示异常。
有人可以请让我知道,如何获得例外
1条答案
按热度按时间krcsximq1#
您可以通过调用
result
函数来查找查询的错误状态。对于您的需求,您可以考虑以下代码:示例:
错误: