你好,
我希望你能幫我找出我失蹤。
我想做一個簡單的事情。讀取數據從數據攝入區(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)它成功運行和表添加到目標模式。
但是當我試圖創建一個共享表不顯示。
上麵的表可以創建共享的筆記本df.write.saveAsTable ()。
閱讀時可用的文檔我看過的通過三角洲分享STREAMING_TABLE不能共享。
也許我忽略了某些設置?這將是偉大的,如果你能幫我弄出來。
謝謝。
