Pyspark Delta Lake 捕获表不是 delta 表异常

Question

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

它给出的例外是'/abc'不是Delta表。;

我想在找不到文件时执行特定操作。 是否已经有一个类可以像 FileNoTFoundException 一样单独捕获它 - 这似乎在这里不起作用。

Answer 1

在 pyspark 3.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)