模块＆＃x27; dlt＆＃x27;没有属性＆＃x27; table＆＃x27; -Databricks和Delta Live Tables

发布于 2025-01-29 12:23:11 字数 597 浏览 7 评论 0 原文

我是Databricks和Delta Live Tables的新手。我在Python创建Delta Live Table有问题。

如何从filestore中的json文件中创建delta live表？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

梦在深巷 2025-02-05 12:23:11

它是一个装饰器，所以我认为您还需要一个功能。意思

@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

是在银函数中，您可以将其读取为：

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

也是从屏幕截图中，我不确定，您是作为管道运行的，还是要运行笔记本电脑？后者不起作用。

It is a decorator, so I think you also need a function after. Meaning

@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

In silver function then you can read it as:

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

Also from your screenshots I am not sure, are you running all this as a pipeline or are you trying to run a Notebook? The latter does not work.

回复收藏 0 原文

最冷一天 2025-02-05 12:23:11

桑德罗的答案应该解决您的问题。对于使用实时桌子摄入JSON文件，您可以在某些用例中查看本文“ rel =“ nofollow noreferrer”> https://medium.com/@chaobioz/create-delta-live-tables-dlt-dlt-dlt-dynamisaly-with-pyspark-e06a718199c8

同样也可以生产，最好将自动装载机作为生产出色地。