如何結構化流數據加載到三角洲表在ADLS代是誰的位置

[al -]

你好,

我工作在一個流媒體數據處理。我開始一步從azure eventhub使用readstream讀取數據。現在我想writestream成δ表。

我的要求是,數據應該出現在外部位置(adls gen2)和表應該在我metastore可用。

當我嚐試以下代碼

Code_Snippet:

ext_table_location = " adls路徑”

autoloader_df。writeStream \

.format \(“δ”)

.outputMode \(“追加”)

.option (“checkpointLocation”, checkpoint_directory) \

.option (“mergeSchema”,“真正的”)\

.option(“路徑”,ext_table_location) \

.table (ext_table_location)

它是失敗的。有沒有流數據的標準方法對於這樣的場景嗎?

提前謝謝!

[werners1]

如果你寫在三角洲格式路徑,路徑和創建一個非托管表,應該工作。

[Kaniz]

嗨@Harun消除Basheer,我們還沒有聽到來自你自從上次反應@Werner Stinckens,我檢查,看看他的建議幫助你。

否則,如果你有任何解決方案,請與社區分享,因為它可以幫助別人。

同時,請別忘了點擊“選擇最佳”按鈕時提供的信息幫助解決你的問題。