ADS 层数据计算完成后,接下来使用 Sqoop 将数据导出到 MySQL 中。
MySQL ADS 创建
在 MySQL 节点(Node02)的 /home/warehouse/sql 目录下编写 mysql_gmv_ddl.sql,创建数据表:
vim /home/warehouse/sql/mysql_gmv_ddl.sql
SQL 脚本如下:
-- 进入数据库
use mall;
-- 创建 GVM 统计表
create table ads_gmv_sum_day
(
dt varchar(200) COMMENT '统计日期',
mv_count varchar(200) COMMENT '当日 gmv 订单个数',
gmv_amount varchar(200) COMMENT '当日 gmv 订单总金额',
gmv_payment varchar(200) COMMENT '当日支付金额'
)
COMMENT '每日 GMV 统计';
将 mysql_gmv_ddl.sql 导入到 MySQL 中:
export MYSQL_PWD=DBa2020*
mysql -uroot mall < /home/warehouse/sql/mysql_gmv_ddl.sql
数据导出
在 Sqoop 节点(Node03)的 /home/warehouse/shell 目录下编写 Sqoop 导出脚本,完成数据导入操作: