Pyspark Delta湖泊捕获表不是delta表例外

Question

try:
    df1=spark.read.format("delta").load("/abc")
except Exception as ex:
  print(ex)

它的例外是'/abc‘不是增量表。

我想在找不到文件时执行特定的操作。有没有一个类已经可以单独捕获它了，比如FileNoTFoundException --它在这里似乎不起作用。

Answer 1

在PySpark3.x中，一个不存在的表会抛出通用pyspark.sql.utils.AnalysisException。

这是从Java/Scala层转换而来的。不幸的是，不存在特定于“找不到文件”的异常。

from pyspark.sql.utils import AnalysisException

try:
    spark.read.format("delta").load("/abc")
except AnalysisException as ex:
    print(ex)