想知道社區成員反饋以下代碼可以被指定為特定的工作表,這可以參數化和運行。
但這是最好的方法來管理(刪除不必要的文件δ外部存儲在ADLS)的表。請讓我知道。
def file_exists_delete(路徑):嚐試:dbutils.fs.ls(路徑)dbutils.fs.rm(路徑)打印(“刪除文件”+路徑)返回True除了異常e:如果io。FileNotFoundException”str (e):返回False:提高#分離細胞中複製火花。sql(“優化tbl_name”) df =火花。sql(“真空tbl_name保持0小時排練”)#分離細胞中複製df_collect = df.collect() #在分離細胞和執行複製行df_collect: file_exists_delete(行[0])
