DataCenterGame/app/etl/data_stat_daily.py

from model.DateUtils import DateUtils
from data_stat_task import *
from sync_to_ck_task import *
du = DateUtils()
from model.DingTalkUtils import DingTalkUtils
yestoday = du.get_n_days(-1)
today = du.get_n_days(0)



def run(ymd):
    try:
        # 公众号元数据
        channel_by_account_daily(ymd)
        channel_info_daily(ymd)

        # 清洗订单表-同步到ck
        ods_order(ymd)
        order_sync_ck(ymd)

        # 公众号维度数据-同步到ck
        dw_daily_channel_cost(ymd)
        dw_order_channel_cost_sync_ck(ymd)
    except Exception as e:
        DingTalkUtils.send("数据ETL出错：",'18860455786')



if __name__ == '__main__':
    run(yestoday)
    dw_daily_channel()