Azure Databricks Python创建Delta表无事务日志报错咨询

你使用的CREATE TABLE <表名> USING DELTA LOCATION <路径>语法，作用是将路径下已经存在的Delta表注册到Hive元数据中，不会主动创建新的Delta表。
该语法执行时会强制检查指定路径的根目录下是否存在Delta表的核心标识_delta_log事务日志目录，你当前指定的/mnt/ops/test/alerts路径下不存在该目录，因此抛出异常。

根据你的实际诉求二选一即可：

场景1：需要在该路径下创建全新的空Delta表 #

不要直接用你原来的无表结构建表语句，选任意一种方式初始化：

• 方式1：建表SQL中明确定义表结构，执行后会自动在目标路径生成_delta_log完成表初始化

CREATE TABLE ops.test_alerts (
  -- 替换为你实际业务需要的字段、类型、约束
  alert_id STRING,
  alert_level STRING,
  trigger_time TIMESTAMP,
  alert_content STRING
)
USING DELTA
LOCATION '/mnt/ops/test/alerts'

• 方式2：先通过DataFrame API写入空数据初始化Delta表结构，再执行元数据注册

delta_save_path = "/mnt/ops/test/alerts"
# 定义和业务匹配的表结构
table_schema = "alert_id STRING, alert_level STRING, trigger_time TIMESTAMP, alert_content STRING"
# 构造对应结构的空DataFrame，以delta格式写入目标路径，自动生成事务日志
empty_df = sqlContext.createDataFrame([], schema=table_schema)
empty_df.write.format("delta").save(delta_save_path)
# 初始化完成后再执行你原来的注册语句即可正常运行
sqlContext.sql("CREATE TABLE ops.test_alerts USING DELTA LOCATION '" + delta_save_path + "'")

场景2：需要注册已经存在的Delta表 #

说明你填写的路径配置错误，按以下方向排查：

• 检查上游写入该路径的作业是否使用format("delta")作为写入格式：如果上游用parquet、csv等其他格式写入，路径下永远不会生成Delta事务日志，无法以Delta格式建表。
• 检查路径是否为Delta表的根目录：如果误将分区子路径（比如按天/按类型划分的分区目录）填为表路径，会找不到上级目录下的_delta_log，逐层向上查找存在_delta_log目录的层级，就是正确的表根路径。

内容的提问来源于stack exchange，提问作者Europa