最終解決方案看起來像這樣
首先計算變量的位置(一個月回來今天在我的例子中)
#首先計算歸檔日期(或者其他你需要動態的)從dateutil進口datetime。relativedelta進口relativedelta start_date = datetime.date.today () archive_date = start_date - relativedelta(月= 1)archive_date = archive_date.strftime (% Y - % m) #使用前麵計算的變量構建表導入pyspark.sql。會議文件夾=“容器/文件夾”+ archive_date +”。鑲花的火花。sql (f”使用鑲花的位置創建表存檔/ mnt /{文件夾}”)
找不到SQL方法工作由於某種原因,但這絕對是對我所需要的東西。
許多感謝您的幫助,這將證明v將來有用。
作為一個觀察可能是值得更新磚文檔,因為它目前的狀態位置必須是一個字符串?隻是一個想法。
