取消
顯示的結果
而不是尋找
你的意思是:

為分布、遷移腳本嵌入到圖書館

matty_f
新的貢獻者二世

我工作在一個python包,可以通過pip安裝。包將管理一個三角洲表用戶,和新版本的包可能需要這個表上運行遷移

這是一個好的格式使用?

def遷移(table_path): mm_path = f“{table_path} / _migration_marker”標誌= 0試題:= int (dbutils.fs標誌。頭(mm_path 10))除了異常e:如果“io。FileNotFoundException”str (e):打印(“移民標記未找到”)其他:e如果標記< 1:sql = f”“catalog.schema“創建表。表名…位置{table_path}”“spark.sql (sql) .count () = 1 dbutils.fs標誌。把(mm_path,標記,真的)if marker < 2: sql = f"""ALTER TABLE catalog.schema.tablename ...""" spark.sql(sql).count() marker = 2 dbutils.fs.put(mm_path, marker, True)

1回複1

matty_f
新的貢獻者二世

沒有多少社區發生了

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map