任务开发

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

DWS 明细汇总表开发 - 图1

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

DWS 明细汇总表开发 - 图2

步骤三:输入文件夹名称dws,点击“确定”完成配置。

DWS 明细汇总表开发 - 图3

步骤四:选择已创建的DWS_cookbook文件夹,右键选择“新建任务”。

DWS 明细汇总表开发 - 图4

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

DWS 明细汇总表开发 - 图5

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

DWS 明细汇总表开发 - 图6

步骤七:双击SQL节点,在SQL编辑器中,复制粘贴如下代码。记得修改库名。

insert
  OVERWRITE TABLE 库名.dws_trade_order_cus_1d partition (dt = '${azkaban.flow.1.days.ago}')
SELECT
   order_date,
   cus_id,
   cus_name,
   age,
   item_id,
   sum(item_qty) as item_qty,
   sum(item_amt) as item_amt, 
   item_name, 
   brand 
FROM(
    SELECT
  order_id,
  cus_id,
  cus_name,
  age,
  item_id,
  item_qty,
  item_amt,
  order_date,
  item_name,
  cus_address,
  ip,
  id_card,
  brand
from
  库名.dwd_trade_order_df
where
  dt = '${azkaban.flow.1.days.ago}'
)t1
group by    
   order_date,
   cus_id,
   cus_name,
   age,
   item_id,
   item_name, 
   brand;

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

DWS 明细汇总表开发 - 图7

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

DWS 明细汇总表开发 - 图8

调度配置

步骤一:点击【调度设置】按钮进行调度编辑。

DWS 明细汇总表开发 - 图9

步骤二:开启调度功能,设置调度时间。

DWS 明细汇总表开发 - 图10

步骤三:在【编辑调度】的页面,需要进行调度、跨流依赖以及执行设置,此处主要介绍跨流依赖跨流设置方法,点击“智能推荐”按钮。

DWS 明细汇总表开发 - 图11

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

DWS 明细汇总表开发 - 图12

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

DWS 明细汇总表开发 - 图13

步骤六:点击“确定”按钮,完成调度编辑。

DWS 明细汇总表开发 - 图14

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