概述
通过上面的步骤，已经完成数据中台ODDA建模，接下来实战一下。
GMV（全称Gross Merchandise Volume），即商品交易总额，是成交总额（一定时间段内）的意思。多用于电商行业，一般包含拍下未支付订单金额。
在电商网站定义里面是网站成交金额。这个实际指的是拍下订单金额， 包含付款和未付款的部分。
需求
ADS层分析
计算GMV，包含付款和未付款的部分。
建表
- ads_gmv_ddl.sql
-- 进入数据库
use mall;
-- 创建gmv表
drop table ads_gmv_sum_day;
create table ads_gmv_sum_day
(
dt string comment '统计日期 ' ,
gmv_count bigint comment '每日gmv订单个数',
gmv_amount decimal(16,2) COMMENT '每日gmv订单总金额',
gmv_payment decimal(16,2) COMMENT '当日支付金额'
) COMMENT '每日GMV统计'
row format delimited fields terminated by '\t'
location '/warehouse/mall/ads/ads_gmv_sum_day/'
- 执行建表文件
hive -f /home/warehouse/sql/ads_gmv_ddl.sql
脚本
- 编写脚本，完成dws的数据处理
#!/bin/bash
# 定义变量方便修改
APP=mall
hive=hive
# 如果是输入的日期按照取输入日期；如果没输入日期取当前时间的前一天
if [ -n $1 ] ;then
log_date=$1
else
log_date=`date -d "-1 day" +%F`
fi
sql="
set hive.exec.dynamic.partition.mode=nonstrict;
insert into table "$APP".ads_gmv_sum_day
select
'$log_date' dt ,
sum(order_count) gmv_count ,
sum(order_amount) gmv_amount ,
sum(payment_amount) payment_amount
from "$APP".dws_user_action
where dt ='$log_date'
group by dt
;
"
$hive -e "$sql"
- 执行脚本
[root@node03 shell]# ./ads_gmv.sh 2021-03-24
验证结果
hive> select * from ads_gmv_sum_day ;
OK
2021-03-24 300 160700 80931
Time taken: 0.109 seconds, Fetched: 1 row(s)
