|
@@ -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_)
|