DataCenterGame/app/etl/sync_to_ck_hourly.py

"""同步到 ck 小时调度"""

from model.DataBaseUtils import MysqlUtils,CkUtils
from model.DateUtils import DateUtils
from model.log import logger
log=logger()
db = MysqlUtils()
ck = CkUtils()
dt = DateUtils()
import sys
from model.DingTalkUtils import DingTalkUtils
from datetime import datetime
from sync_to_ck_task import *


def run():

    try:
        order(ymd)
    except:
        DingTalkUtils.send("[order]同步到ck出错:",'18860455786')
    try:
        daily_qq(ymd)
    except:
        DingTalkUtils.send("[daily_qq]到ck出错:", '18860455786,')
    try:
        daily_vx(ymd)
    except:
        DingTalkUtils.send("[daily_vx]同步到ck出错", '18860455786,')



if __name__ == '__main__':
    ymd = dt.get_n_days()
    log.debug("run  " + ymd)
    run()