取消
顯示的結果
而不是尋找
你的意思是:

問題共享一個流表中創建表通過生活δ共享

vkuznetsov
新的貢獻者二世

你好,

我希望你能幫我找出我失蹤。

我想做一個簡單的事情。讀取數據從數據攝入區(csv文件保存到Azure存儲賬戶)使用三角洲生活表管道並分享結果表到另一個磚工作區使用三角洲共享。

這裏的代碼描述了DLT管道。

從pyspark.sql進口dlt。函數從pyspark.sql進口*。類型導入* raw_path = @dlt“/ mnt /攝入/感讀數”。表(評論=包含數據從傳感器接收API) def sensors_raw(): #裝載器裝載新攝取的文件。df = spark.readStream.format (cloudFiles) \ .option (“cloudFiles。形式at", "csv") \ .option("header",True) \ .load(raw_path) return (df)

它成功運行和表添加到目標模式。

vkuznetsov_0 - 1689259588838. - png

但是當我試圖創建一個共享表不顯示。

2023年_07_13_16_48_52_data_explorer.png

上麵的表可以創建共享的筆記本df.write.saveAsTable ()。

閱讀時可用的文檔我看過的通過三角洲分享STREAMING_TABLE不能共享。

也許我忽略了某些設置?這將是偉大的,如果你能幫我弄出來。

謝謝。

1回複1

vkuznetsov
新的貢獻者二世

對不起,我想我已經在錯誤的線程創建的。創造了同樣的帖子社區灣

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map