Azure数据流Databricks Delta Live Tables报错：未发现任何表

错误信息 #

尝试更新空管道。
此错误通常表示在指定的Notebook库中未发现任何表。
请验证Notebook库中是否包含表定义。

关联的DLT笔记本代码 #

%python

import dlt
@dlt.table
def kafka_raw():
    TOPIC = "<event_hub>"
    BOOTSTRAP_SERVERS = "<event_hub>.servicebus.windows.net:9093"
    EH_SASL = 'kafkashaded.org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://<event_hub>.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=<event_hub shared_access_policy primary_key>";;'

    return (
        spark.readStream.format("kafka")
        .option("subscribe", TOPIC)
        .option("kafka.bootstrap.servers", BOOTSTRAP_SERVERS)
        .option("kafka.sasl.mechanism", "PLAIN")
        .option("kafka.security.protocol", "SASL_SSL")
        .option("kafka.sasl.jaas.config", EH_SASL)
        .option("kafka.request.timeout.ms", "60000")
        .option("kafka.session.timeout.ms", "60000")
        .option("failOnDataLoss", "false")
        .option("startingOffsets", "earliest")
        .load()
    )

问题分析与解决方案 #

报错核心是DLT未识别到有效的表定义，可按以下步骤排查：

• 确认笔记本关联关系：检查DLT管道配置中，选定的Notebook库是否包含当前笔记本，路径是否正确。
• 验证装饰器与导入：确保import dlt语句无报错，@dlt.table装饰器拼写正确，没有被注释或语法错误打断。
• 排查代码语法问题：替换代码中所有<event_hub>类占位符为实际值，确保函数内无语法错误（语法错误会导致脚本执行失败，DLT无法解析表定义）。
• 检查运行环境：确认使用的Databricks Runtime版本支持DLT（推荐10.4 LTS及以上），集群配置符合DLT要求。
• 手动验证表识别：在笔记本中单独运行import dlt和表定义代码段，确认无报错后重启DLT管道。

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