This commit is contained in:
Yam ZhengLim
2022-09-25 19:25:45 +08:00
parent 40aaa1f5e6
commit 945ea5ce4b
8 changed files with 35 additions and 5 deletions
+2
View File
@@ -42,6 +42,8 @@ def exchange_load_to_cloudstorage(EXCHANGE_CSV_TEMP_STORAGE_PATH):
def main():
#Extract Load Exchange Data, and delete the temp csv
EXCHANGE_CSV_TEMP_STORAGE_PATH = "./exchange/extract/exchange_temp_extract_csv/"
if not os.path.exists(EXCHANGE_CSV_TEMP_STORAGE_PATH):
os.makedirs(EXCHANGE_CSV_TEMP_STORAGE_PATH)
exchange_extract(EXCHANGE_CSV_TEMP_STORAGE_PATH)
exchange_load_to_cloudstorage(EXCHANGE_CSV_TEMP_STORAGE_PATH)
general_function.delete_csv_in_path(EXCHANGE_CSV_TEMP_STORAGE_PATH)