From 9283d77f48822ffeec173e602441fb95dbbda12f Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Tue, 23 Aug 2022 19:16:26 +0800 Subject: [PATCH] auto create extract_temp_csv folder --- exchange/extract/exchange_extract_function.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/exchange/extract/exchange_extract_function.py b/exchange/extract/exchange_extract_function.py index 7fd28e8..b99115d 100644 --- a/exchange/extract/exchange_extract_function.py +++ b/exchange/extract/exchange_extract_function.py @@ -1,6 +1,7 @@ import csv from operator import concat import mysql.connector +import os def connect_mysql(config): @@ -18,6 +19,13 @@ def connect_mysql(config): def mysql_dict_sql_to_csv(SQL_DICT, path, mysqldb, mysqlcursor): + temp_folder_path = path + # Check whether the specified path exists or not + temp_folder_path_isExist = os.path.exists(temp_folder_path) + if not temp_folder_path_isExist: + # Create a new directory because it does not exist + os.makedirs(temp_folder_path) + print("[Create Folder] exchange_temp_extract_csv") for tablename,sql in SQL_DICT.items():