This commit is contained in:
Yam ZhengLim
2022-09-25 21:04:41 +08:00
parent d584c84508
commit 4ebc64401c
3 changed files with 1 additions and 3 deletions
-2
View File
@@ -42,8 +42,6 @@ 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)