getReport data-call back

start_sync_amz.py

@@ -254,6 +254,9 @@ def pre_func(AWS_CREDENTIALS,date_):
         # sd_report.reportV2_adGroupsRecord_t2_ETL(conn,params=para)
         # sd_report.reportV2_adGroupsRecord_t3_ETL(conn,params=para)
         # sd_report.reportV2_asins_t2_ETL(conn,params=para)
+
+
+
         # sd_report.reportV2_asins_t3_ETL(conn,params=para)
         # sd_report.reportV2_productAds_t2_ETL(conn,params=para)
         # sd_report.reportV2_productAds_t3_ETL(conn,params=para)
@@ -311,6 +314,7 @@ def amz_report(AWS_CREDENTIALS,para=None):
         try:
             refresh_token = shop_infos(AWS_CREDENTIALS['profile_id'])['refresh_token']
             AWS_CREDENTIALS['refresh_token'] = refresh_token
+            pre_func(AWS_CREDENTIALS,date_)
         except Exception as e:
             print(e)
 
@@ -373,10 +377,10 @@ if __name__ == '__main__':
 
     timezone_ = Common_ETLMethod(**AWS_CREDENTIALS).timeZone()
     print(timezone_)
-    # amz_report(AWS_CREDENTIALS)
-    sched = BlockingScheduler()
-    sched.add_job(amz_report,'cron',hour=17,minute=0,second=0,timezone=timezone_, args=(AWS_CREDENTIALS, ))#,params={"startDate":"2023-11-04","endDate":"2023-11-04","date":"20231104"}
-    sched.start()
+    amz_report(AWS_CREDENTIALS)
+    # sched = BlockingScheduler()
+    # sched.add_job(amz_report,'cron',hour=17,minute=0,second=0,timezone=timezone_, args=(AWS_CREDENTIALS, ))#,params={"startDate":"2023-11-04","endDate":"2023-11-04","date":"20231104"}
+    # sched.start()