如何在 PySpark 中导入 AnalysisException

【问题标题】：How to import AnalysisException in PySpark如何在 PySpark 中导入 AnalysisException
【发布时间】：2021-04-05 10:12:54
【问题描述】：

我找不到如何在 PySpark 中导入 AnalysisException，所以我可以抓住它。例如：

df = spark.createDataFrame([[1, 2], [1, 2]], ['A', 'A'])

try:
  df.select('A')
except AnalysisException as e:
  print(e)

错误信息：

NameError: name 'AnalysisException' is not defined

【问题讨论】：

【解决方案1】：

你可以在这里导入：

from pyspark.sql.utils import AnalysisException

这显示在错误回溯中

Traceback (most recent call last):
  ...
  File "<string>", line 3, in raise_from
pyspark.sql.utils.AnalysisException: cannot resolve ...

【讨论】：