模块“dlt”没有属性“表”-databricks 和 delta live 表

Question

我是 databricks 和 delta live 表的新手。我在 python 中创建增量实时表时遇到问题。

如何从文件存储中的 json 文件创建增量实时表？

Answer 1

它是一个装饰器，所以我认为你还需要一个函数。意义

@dlt.table(comment="your comment")
def get_bronze():
    df=spark.sql("""select * from myDb.MyRegisterdTable""")
    #If you wanna check logs:
    #print("bronze",df.take(5),"end")
    return df

在 silver 函数中，您可以将其读作：

@dlt.table
def get_silver():
    df = dlt.read("get_bronze")
    [..do_stuff...]
    return df

另外，从您的屏幕截图中，我不确定您是否将所有这些作为管道运行，或者您是否尝试运行笔记本？后者不起作用。