大家好!
我有一個管道數據工廠的筆記本。我有以下的筆記本(在一個函數需要寫一個查詢一個表):
”
試一試:
df = spark.sql(查詢)
df.write.format(格式).mode(方法).saveAsTable(表)
除了例外e:
(? ? ?)
”
我希望,如果代碼進入這個“除了異常e:”部分,筆記本的中止(這在管道DF筆記本顯示為“失敗”)。
我試過這個方法:
1)
e
2)
提高異常(“錯誤”)
3)
維護錯誤
4)
味精= "寫表的查詢時出錯:{}“.format (e)
dbutils.notebook.exit(味精)
沒有人喜歡我想要的工作。我想要筆記本失敗。最後一個實際上阻止細胞的其餘部分執行,但它仍然出現在數據工廠“成功”,我想“失敗”。
有誰知道我怎麼能這樣做呢?
請和謝謝! !
