Databricks流DataFrame写入Delta银表遇AnalysisException报错求助

报错原因很明确：流DataFrame/Dataset不能使用常规的write API，必须用结构化流专用的writeStream API。

你需要修改保存代码，替换write为writeStream，同时必须添加流处理必需的checkpointLocation配置（用于记录流处理进度，实现故障恢复）。

修改后的完整代码 #

# 流DataFrame定义（保持不变）
df_streaming = spark.sql(SQL_TELEMETRY_JOB).coalesce(1)

# 流输出到Delta银表
(df_streaming
 .writeStream
 .mode("append")
 .format("delta")
 .option("checkpointLocation", "/dbfs/your-silver-table-checkpoint/telemetry_job2")  # 替换为实际检查点路径
 .saveAsTable(silver.telemetry_job2)
)

关键说明 #

• checkpointLocation：必须指定一个DBFS路径（比如/dbfs/mnt/silver/checkpoints/telemetry_job2），这个路径会存储流处理的元数据和状态信息，确保流任务中断后可以从上次的位置继续运行。
• 如果你的spark.sql(SQL_TELEMETRY_JOB)实际返回的是静态DataFrame（比如查询的是普通Delta表而非流数据源），可以执行print(df_streaming.isStreaming)验证：如果输出False，说明是静态DF，此时直接用原来的write API即可，报错可能是因为你误将静态DF当成了流DF，或者SQL查询的数据源实际是流类型。

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