你好,
我試圖設置DLT管道,其基本管道測試目的我麵臨的問題而啟動管道,任何幫助都是感激
代碼:
@dlt.table (name = " dlt_bronze_cisco_hardware ")
def dlt_cisco_networking_bronze_hardware ():
回報(
spark.readStream.format \ (“cloudFiles”)
.option (“cloudFiles。”、“json格式”)\
.option (“cloudFiles.schemaLocation”、“abfss: / /(電子郵件保護)/ DLT_Schema”)\
.load (“abfss: / /(電子郵件保護)/著陸/ DLT_Testing /硬件/ * / * / * / * . json”)
)
spark.databricks.repl @Arumugam拉馬錢德蘭請刪除”。allowedLanguages“DLT集群配置如果你有政策。DLT僅適用於python和SQL筆記本不管怎麼說,我們也不需要顯式地設置這個配置。