任务开发

步骤一：从左侧导航栏选择【开发运维】-【离线开发】进入离线开发页面。

步骤二：选择已创建的cookbook文件夹，右键选择“新建文件夹”。

步骤三：输入文件夹名称ads，点击“确定”完成配置。

步骤四：选择已创建的ads文件夹，右键选择“新建任务”。

步骤五：在弹出的对话框中填写任务名称ads_product_brand_cusanalysis_df，其它配置可选择默认。

步骤六：将SQL节点拖入到画布中，命名为ads_product_brand_cusanalysis_df_1，将SQL节点和虚拟节点进行连接。

步骤七：双击SQL节点，在SQL编辑器中，复制粘贴如下代码。

INSERT
  OVERWRITE TABLE 库名.ads_product_brand_cusanalysis_df partition (dt = '${azkaban.flow.1.days.ago}')
SELECT
  brand,
  SUM(item_qty) as item_qty,
  SUM(item_amt) as order_amt
FROM
  库名.dws_trade_order_cus_1d
where
  dt = '${azkaban.flow.1.days.ago}'
GROUP BY
  brand;

步骤八：全选任务，点击“运行”进行测试。

步骤十一：在弹出的对话框中，使用默认配置点击“运行”即可。

步骤十二：按照步骤一到十一完成任务ads_customer_cusanalysis_df的开发，复制粘贴如下代码。

INSERT
  OVERWRITE TABLE 库名.ads_customer_cusanalysis_df partition (dt = '${azkaban.flow.1.days.ago}')
SELECT
  age_group,
  COUNT(DISTINCT cus_id) AS cus_count,
  SUM(item_qty) AS total_qty,
  SUM(item_amt) AS amount
FROM
  (
    SELECT
      cus_id,
      cus_name,
      age,
      item_qty,
      item_amt,
      CASE
        WHEN age <= 18 THEN '18岁以下'
        WHEN age <= 25 THEN '19~25岁'
        WHEN age <= 35 THEN '26~35岁'
        WHEN age <= 45 THEN '36~45岁'
        ELSE '45岁以上'
      END AS age_group
    FROM
      库名.dws_trade_order_cus_1d
    where dt = '${azkaban.flow.1.days.ago}'
  ) t
GROUP BY
  age_group;

调度配置

步骤一：回到ads_product_brand_cusanalysis_df任务，点击【调度设置】按钮进行调度编辑。

步骤二：开启调度功能，设置调度时间。

步骤三：点击“智能推荐”按钮。在【任务依赖的智能推荐】的页面查看节点输出表和输入表，勾选后点击“下一步”。

步骤四：检查依赖关系，确认无误后，点击“完成”按钮完成配置。

步骤五：点击“确定”按钮，完成调度编辑。

步骤六：按照步骤一到五完成任务ads_customer_cusanalysis_df的调度配置。