|
@@ -1,10 +1,11 @@
|
|
|
from sync_amz_data.tasks.account import AccountTask
|
|
|
from sync_amz_data.settings import LOG_CONF
|
|
|
+import logging.config
|
|
|
+logging.config.dictConfig(LOG_CONF)
|
|
|
from sync_amz_data.DataTransform import Data_ETL
|
|
|
from sync_amz_data.DataTransform.Data_ETL import Common_ETLMethod,SP_ETL,SB_ETL,SD_ETL
|
|
|
-import logging.config
|
|
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
|
-logging.config.dictConfig(LOG_CONF)
|
|
|
+
|
|
|
|
|
|
def amz_report(AWS_CREDENTIALS,para={}):
|
|
|
conn = SB_ETL(**AWS_CREDENTIALS).clickhouse_connect()
|
|
@@ -80,12 +81,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=8,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=17,minute=0,second=0,timezone=timezone_)#,params={"startDate":"2023-11-04","endDate":"2023-11-04","date":"20231104"}
|
|
|
|
|
|
sched.start()
|
|
|
|
|
|
|
|
|
- # list_date = ["2023-10-07",]
|
|
|
+ # list_date = ["2023-10-09",]
|
|
|
# for date_ in list_date:
|
|
|
# print(date_)
|
|
|
# print(date_.replace("-",""))
|