Merge branch 'yifan' of ASJ_ADS/sync_amz_data into master

start_sync_amz.py

@@ -7,8 +7,11 @@ from apscheduler.schedulers.blocking import BlockingScheduler
 
 
 def amz_report(AWS_CREDENTIALS,para=None):
-    refresh_token = shop_infos(AWS_CREDENTIALS['profile_id'])['refresh_token']
-    AWS_CREDENTIALS['refresh_token'] = refresh_token
+    try:
+        refresh_token = shop_infos(AWS_CREDENTIALS['profile_id'])['refresh_token']
+        AWS_CREDENTIALS['refresh_token'] = refresh_token
+    except Exception as e:
+        print(e)
 
     conn = SB_ETL(**AWS_CREDENTIALS).clickhouse_connect()
     sb_report = SB_ETL(**AWS_CREDENTIALS)
@@ -86,8 +89,11 @@ if __name__ == '__main__':
         'lwa_client_secret': 'cbf0514186db4df91e04a8905f0a91b605eae4201254ced879d8bb90df4b474d',
         'profile_id': "3006125408623189"
     }
-    refresh_token = shop_infos(AWS_CREDENTIALS['profile_id'])['refresh_token']
-    AWS_CREDENTIALS['refresh_token'] = refresh_token
+    try:
+        refresh_token = shop_infos(AWS_CREDENTIALS['profile_id'])['refresh_token']
+        AWS_CREDENTIALS['refresh_token'] = refresh_token
+    except Exception as e:
+        print(e)
 
     timezone_ = Common_ETLMethod(**AWS_CREDENTIALS).timeZone()
     print(timezone_)