45 lines
1.0 KiB
Python
45 lines
1.0 KiB
Python
|
from utils.read_sql_files import read_sql_files
|
|||
|
|
from apscheduler.schedulers.background import BlockingScheduler
|
|||
|
|
from utils.log import Log
|
|||
|
|
import logging
|
|||
|
|
|
|||
|
|
# 配置logging以控制日志输出
|
|||
|
|
logger = logging.getLogger('apscheduler')
|
|||
|
|
# 设置logger的级别为WARNING，这样INFO级别的日志就不会被处理了
|
|||
|
|
logger.setLevel(logging.WARNING)
|
|||
|
|
|
|||
|
|
|
|||
|
|
def dim():
|
|||
|
|
read_sql_files('dim')
|
|||
|
|
|
|||
|
|
|
|||
|
|
def dwd():
|
|||
|
|
read_sql_files('dwd_before')
|
|||
|
|
read_sql_files('dwd_after')
|
|||
|
|
|
|||
|
|
|
|||
|
|
def dws():
|
|||
|
|
read_sql_files('dws_before')
|
|||
|
|
read_sql_files('dws_after')
|
|||
|
|
|
|||
|
|
|
|||
|
|
def ads():
|
|||
|
|
read_sql_files('ads')
|
|||
|
|
|
|||
|
|
|
|||
|
|
if __name__ == '__main__':
|
|||
|
|
log = Log().getlog()
|
|||
|
|
log.info(f"---------job开始执行:---------")
|
|||
|
|
|
|||
|
|
sch = BlockingScheduler(timezone='Asia/Shanghai')
|
|||
|
|
# 每天4点执行dim
|
|||
|
|
sch.add_job(dim, 'cron', hour=4, minute=0)
|
|||
|
|
# 每天5点执行执行dwd
|
|||
|
|
sch.add_job(dwd, 'cron', hour=5, minute=0)
|
|||
|
|
# 每天6点十分执行dws
|
|||
|
|
sch.add_job(dws, 'cron', hour=6, minute=10)
|
|||
|
|
# 每天七点十分执行ads
|
|||
|
|
sch.add_job(ads, 'cron', hour=7, minute=10)
|
|||
|
|
|
|||
|
|
sch.start()
|