任务开发

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

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

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

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

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

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

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

INSERT
  OVERWRITE TABLE 库名.dwd_trade_order_df partition (dt = '${azkaban.flow.1.days.ago}')
select
  t1.order_id,
  t1.cus_id,
  t2.cus_name,
  t2.age,
  t1.item_id,
  t1.qty,
  t1.amount,
  t1.order_date,
  t3.item_name,
  t2.cus_address,
  t2.ip,
  t2.id_card,
  t3.brand
from
  (
    SELECT
      order_id,
      cus_id,
      item_id,
      qty,
      amount,
      order_date
    FROM
      库名.ods_order_info_df
    where
      dt = '${azkaban.flow.1.days.ago}'
  ) t1
  left join (
    select
      cus_id,
      cus_name,
      age,
      cus_address,
      ip,
      id_card
    from
      库名.dim_customer_cus_info_df
    where
      dt = '${azkaban.flow.1.days.ago}'
  ) t2 on t1.cus_id = t2.cus_id
  left join (
    select
      item_id,
      item_name,
      brand
    from
      库名.dim_product_item_info_df
    where
      dt = '${azkaban.flow.1.days.ago}'
  ) t3 on t1.item_id = t3.item_id;

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

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

调度配置

步骤一： 点击【调度设置】开启定时调度。

步骤二：因该任务需等待上游任务运行成功后才能运行，需配置上游依赖。此任务所需依赖的上游比较多，此时可选择【智能推荐】进行添加

步骤三：选择所有本任务所需的输入表。

步骤四：点击下一步，系统会根据血缘关系找到本任务的输入表是由哪一个/哪一些上游任务输出的，然后将上游任务的节点进行引入。

效果如下：

步骤五：智能推荐仅支持sql节点，因此还需要增对数据传输节点的依赖，点击“编辑”按钮。

步骤六：在依赖任务中选择,在依赖节点中选择【末级节点】，并点击“添加”按钮。

其余配置项本案例不做修改，如有疑问请查阅用户手册。