ADS 应用表任务开发
更新时间: 2024-12-04 15:40:43
任务开发
步骤一:从左侧导航栏选择【开发运维】-【离线开发】进入离线开发页面。
步骤二:选择已创建的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的调度配置。