From 2738b8bd82e198e3037352afe7a5480f3e18feda Mon Sep 17 00:00:00 2001
From: Yam ZhengLim <yamzhenglim0427@gmail.com>
Date: Sat, 1 Oct 2022 12:08:19 +0800
Subject: [PATCH] enclose debug

---
 .../exchange_extract_function.cpython-39.pyc  | Bin 1698 -> 1757 bytes
 exchange/extract/exchange_extract_function.py |   2 +-
 .../exchange_load_function.cpython-39.pyc     | Bin 985 -> 1002 bytes
 exchange/load/exchange_load_function.py       |   3 ++-
 requirements.txt                              |   6 +-----
 5 files changed, 4 insertions(+), 7 deletions(-)

diff --git a/exchange/extract/__pycache__/exchange_extract_function.cpython-39.pyc b/exchange/extract/__pycache__/exchange_extract_function.cpython-39.pyc
index 47cadd0f0572040c2ec355e54eb9568c6c74a12d..53fb04aeb8c310f5085de339a2f1489c7227d0cb 100644
GIT binary patch
delta 298
zcmZ3)dzY6tk(ZZ?0SG?rF;8BzkvD{iQE74#lM(m37^YgbTK1|NRSlEpGlhtxaQ3p)
z@|5sr3DoeUaHVjk@bofI{?8<v%2>(3$WY72$WWzM!cxQ6%*e=4!ji&U!_~~h$PmsD
z$&dn+t>X&^iSj{285vUegQ4OE3<f||2)RO_DKK>g4260r48aVV0+Sn=Z`oCGmX@UH
zTId#MrfV|YV$Vx0&&kY7y~UB5mz<xHnV0^HvE~<}k|t9WXG&^LW^QIlYEcwtVQGFz
zYH~(m(d0Ci8;lZ@?OE^1iZKc>axwBS2{3YiXlAazLd->~z(COCC{mbg#iq$E4&)T^
Lf(X^gd2A*C^m9tm

delta 239
zcmcc1yNH)Jk(ZZ?0SMxMm?c+i<PBkBl$xBxWW@a}hN+gVmc8miRmJ4_Od&kI%(Xlv
z{0jtXcos5FW@na7WvKkY$WY72$WWzM!cxQ6%*e=4!ji&S!_~~h$PmsD$&dn+t>X&^
ziE=?i85vTzgQ4OE3<f||2)RO_DKK>g4260r48aVVJd-<_Z*glf-eS*7Ezil!OP#!s
z<p!hZ<SN#CvLcLJK*+-+z{mljnYsQ7F&8NTeWJ-xBs;m3O_N&$$SL9l5lWL+vY7w?
DRCG36

diff --git a/exchange/extract/exchange_extract_function.py b/exchange/extract/exchange_extract_function.py
index 567cdef..4a6888b 100644
--- a/exchange/extract/exchange_extract_function.py
+++ b/exchange/extract/exchange_extract_function.py
@@ -38,7 +38,7 @@ def mysql_dict_sql_to_csv(SQL_DICT, path, mysqldb, mysqlcursor):
             headers = [col[0] for col in mysqlcursor.description] # get headers
             mysqlresult.insert(0, tuple(headers))
             fp = open(concat(path,filename), 'w', newline = '', encoding = 'utf-8-sig') 
-            myFile = csv.writer(fp)
+            myFile = csv.writer(fp,delimiter='|',quotechar='"')
             myFile.writerows(mysqlresult)
             fp.close()
 
diff --git a/exchange/load/__pycache__/exchange_load_function.cpython-39.pyc b/exchange/load/__pycache__/exchange_load_function.cpython-39.pyc
index 61fb23dac41e6ee293762026d21d0f5de83a96b2..66e5026606665041cd57bc6f610e6755a505067a 100644
GIT binary patch
delta 260
zcmcb~{)(M1k(ZZ?0SLaWH&5ndp2#O-uL0zxFr+Z%Fyt~uF*1VKOgT(ZOexGMEG-OC
z%qgrXY(SbNg(;Xpll>(~vnJy$_TrNKqQvx6zljOU8KWk1Fh;Pm17&_?J5Nq$>||t_
z{E<<dk#jRA6Eh<(3s9nn8KjS`h;_0gv$i(K2}Num0;CB-Z~$4i1WF5X@)J|yOY-BB
zN|UowOL!;eGfT7a0Od4UCr@M+wu@p-$}h<`F5(1f1c@UV0X7V54u?%{eoARhsvRRx
OMKQ=G9!3r(4o(2{_%pHq

delta 298
zcmaFGev_Rqk(ZZ?0SN52Fem?In#d<(rU2xnFr+Z%Fyt~uF)}iwFr_fJFhnt>u%xg8
zY33BRU<OV0mmp1=jJMc}OY(~n(^DsAE@!+oS&%V;odYQGD?52|0b{2mGmu@(2U5z&
z#K^<Q#>mIW0fa?dn}wK|8F^WO5=AUPLX)kCZL$)xc0D&pgdIeHjDZlGK-MjR(t@1)
z#FY4w{P?8O<m}WE9-wHk5Rd>F%>{-$VB@(Mi+F*eewr*%Jn8xQ={c!-$vOF@DMd^`
l(ISv%!SYBJfUN@CBF15po1apelWNBZR96gg8V?f(Cjd)NH2eSn

diff --git a/exchange/load/exchange_load_function.py b/exchange/load/exchange_load_function.py
index fa57e23..cc2a706 100644
--- a/exchange/load/exchange_load_function.py
+++ b/exchange/load/exchange_load_function.py
@@ -1,4 +1,5 @@
 from google.cloud import storage
+import boto3
 
 def login_cloudstorage_credential(credential):
     try:
@@ -18,4 +19,4 @@ def upload_to_bucket(storage_client, blob_name, file_path):
     except Exception as e: 
         print(e)
         print("[FUNCTION_ERROR]-upload_to_bucket",blob_name)
-        return False
+        return False
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
index 6bd9f92..15604fe 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,6 +1,2 @@
 mysql-connector-python==8.0.29
-<<<<<<< HEAD
-google-cloud-storage==2.5.0
-=======
-google-cloud-storage==2.5.0
->>>>>>> fd92c3d7ac25862e651876c9287408f2a9610730
+google-cloud-storage==2.5.0
\ No newline at end of file