Merge branch 'yifan' of ASJ_ADS/sync_amz_data into master

start_sync_amz.py

@@ -80,12 +80,12 @@ if __name__ == '__main__':
     timezone_ = Common_ETLMethod(**AWS_CREDENTIALS).timeZone()
     print(timezone_)
     sched = BlockingScheduler()
-    sched.add_job(lambda: amz_report(AWS_CREDENTIALS=AWS_CREDENTIALS),'cron',hour=7,minute=0,second=0,timezone=timezone_)#,params={"startDate":"2023-11-04","endDate":"2023-11-04","date":"20231104"}
+    sched.add_job(lambda: amz_report(AWS_CREDENTIALS=AWS_CREDENTIALS),'cron',hour=8,minute=0,second=0,timezone=timezone_)#,params={"startDate":"2023-11-04","endDate":"2023-11-04","date":"20231104"}
 
     sched.start()
 
 
-    # list_date = ["2023-11-05",]
+    # list_date = ["2023-10-07",]
     # for date_ in list_date:
     #     print(date_)
     #     print(date_.replace("-",""))

sync_amz_data/DataTransform/Data_ETL.py

@@ -1825,7 +1825,7 @@ if __name__ == '__main__':
 
     # SD
     ac_etl = SD_ETL(**AWS_CREDENTIALS)
-    ls = ac_etl.reportV3_asin_sdPurchasedProduct_ETL(conn)
+    ls = ac_etl.reportV2_campaignsRecord_t2_ETL(conn)
     print(ls)
     print(ls.info())
     # print(ls.to_excel('obse11.xlsx'))