export_dwt_flow_asin.py

import os
import sys

sys.path.append(os.path.dirname(sys.path[0]))
from utils.DolphinschedulerHelper import DolphinschedulerHelper
from utils.common_util import CommonUtil


if __name__ == '__main__':

    date_list = ["2024-02","2024-01","2023-12","2023-11","2023-10","2023-09"]
    for date_info in date_list:
        startParams = {
            "site_name": "us",
            "date_type": "month",
            "date_info": date_info
        }
        print(startParams)
        DolphinschedulerHelper.start_and_watch_process_instance(
            "big_data_selection",
            process_df_name='export_dwt_flow_asin_api',
            startParams=startParams
        )

    CommonUtil.send_wx_msg(["chenyuanjie", "wangrui4"], "【export_dwt_flow_asin_api】导出完成", "")

    pass