README.md · 音阶/Bigdata练习题

# 一

## sql准备(仅适用于 ’一‘)

```sql
-- HHDtest.ads_traffic_stats_by_channel
DROP TABLE IF EXISTS HHDtest.ads_traffic_stats_by_channel;
CREATE TABLE HHDtest.ads_traffic_stats_by_channel
(
    `dt`               STRING COMMENT '统计日期',
    `recent_days`      BIGINT COMMENT '日期范围',
    `uv_count`         BIGINT COMMENT '访客人数',
    `avg_duration_sec` BIGINT COMMENT '平均停留时长，单位为秒',
    `avg_page_count`   BIGINT COMMENT '平均浏览页面数',
    `sv_count`         BIGINT COMMENT '会话总数',
    `bounce_rate`      DECIMAL(16, 2) COMMENT '跳出率'
) COMMENT '各渠道流量统计';

-- HHDtest.dwd_user_info
DROP TABLE IF EXISTS HHDtest.dim_user_info;
CREATE TABLE HHDtest.dim_user_info
(
    id                  STRING COMMENT '主键',
    name                STRING COMMENT '用户姓名',
    create_time         TIMESTAMP COMMENT '注册时间'
)   COMMENT '用户表'   ;

--HHDtest.dwd_page_residence_time
DROP TABLE IF EXISTS HHDtest.fact_page_residence_time;
CREATE TABLE HHDtest.fact_page_residence_time
(
    id              STRING COMMENT '主键',
    user_id         STRING COMMENT '用户id',
    page_id         STRING COMMENT '页面',
    go_in_time      TIMESTAMP COMMENT '进入时间',
    out_time        TIMESTAMP COMMENT '离开时间'
) COMMENT '页面停留时间信息表'   ;

--HHDtest.dwd_user_login
DROP TABLE IF EXISTS HHDtest.fact_user_login;
CREATE TABLE HHDtest.fact_user_login
(
    id              STRING COMMENT '主键',
    user_id         STRING COMMENT '用户id',
    login_time      TIMESTAMP COMMENT '登录时间',
    logout_time     TIMESTAMP COMMENT '登出时间'
)   COMMENT '用户登录信息表'   ;

--HHDtest.dwd_page_info
DROP TABLE IF EXISTS HHDtest.dim_page_info;
CREATE TABLE HHDtest.dim_page_info
(
    id              STRING COMMENT '页面id',
    page            STRING COMMENT '页面类型',
    create_time     TIMESTAMP COMMENT '创建时间'
) COMMENT '页面信息表'       ;

DROP TABLE IF EXISTS HHDtest.ads_user_FirstAndSecondToLastAndMaxPage;
CREATE TABLE HHDtest.ads_user_FirstAndSecondToLastAndMaxPage
(
    user_id         STRING COMMENT '用户id',
    user_name       STRING COMMENT '用户姓名',
    first_page      STRING COMMENT '第一次访问页面',
    s_to_last       STRING COMMENT '倒数第二次访问页面（没有倒数第二次则为倒数第一次）',
    max_the_page    STRING COMMENT '最多访问的页面',
    dt              STRING COMMENT '统计日期'
) COMMENT '页面访问统计表';

DROP TABLE IF EXISTS HHDtest.login3and7and14day;
CREATE TABLE HHDtest.login3and7and14day
(
    days                    INT     COMMENT '天数',
    date_range              STRING  COMMENT '范围',
    max_login_in_week       STRING  COMMENT '星期几最多用户',
    lost_users              STRING     COMMENT '范围流失用户数量',
    lost_user_rate          STRING  COMMENT '范围流失率',
    range_login_rate        STRING  COMMENT '登录率'
)   COMMENT '登录情况统计表';

```

数据：

```sql
INSERT INTO TABLE HHDtest.fact_page_residence_time (`id`,`user_id`, `page_id`, `go_in_time`, `out_time`)
VALUES
    ('1','1', '1', '2024-04-25 08:00:00', '2024-04-25 08:15:00'),
    ('2','1', '2', '2024-04-25 08:05:00', '2024-04-25 08:20:00'),
    ('3','2', '3', '2024-04-25 08:10:00', '2024-04-25 08:25:00'),
    ('4','1', '1', '2024-04-24 08:00:00', '2024-04-24 08:16:00'),
    ('5','1', '2', '2024-04-24 08:05:00', '2024-04-24 08:21:00'),
    ('6','1', '3', '2024-04-24 08:10:00', '2024-04-24 08:26:00'),
    ('7','2', '1', '2024-04-18 08:00:00', '2024-04-18 08:17:00'),
    ('8','2', '2', '2024-04-18 08:05:00', '2024-04-18 08:22:00'),
    ('9','2', '3', '2024-04-18 08:10:00', '2024-04-18 08:27:00'),
    ('10','3', '1', '2024-04-11 08:00:00', '2024-04-11 08:18:00');

-- dwd_user_login
INSERT INTO TABLE HHDtest.fact_user_login (`id`, `user_id`, `login_time`, `logout_time`)
VALUES
    ('1', '1', '2024-04-25 08:00:00', '2024-04-25 08:30:00'),
    ('2', '2', '2024-04-25 08:05:00', '2024-04-25 08:35:00'),
    ('3', '3', '2024-04-25 08:10:00', '2024-04-25 08:40:00'),
    ('4', '1', '2024-04-24 08:00:00', '2024-04-24 08:31:00'),
    ('5', '2', '2024-04-24 08:05:00', '2024-04-24 08:36:00'),
    ('6', '3', '2024-04-24 08:10:00', '2024-04-24 08:41:00'),
    ('7', '1', '2024-04-18 08:00:00', '2024-04-18 08:32:00'),
    ('8', '2', '2024-04-18 08:05:00', '2024-04-18 08:37:00'),
    ('9', '3', '2024-04-18 08:10:00', '2024-04-18 08:42:00'),
    ('10', '1', '2024-04-11 08:00:00', '2024-04-11 08:33:00');

-- dwd_page_info
INSERT INTO TABLE HHDtest.dim_page_info (`id`, `page`, `create_time`)
VALUES
    ('1', 'index', '2024-04-25 08:00:00'),
    ('2', 'by_index', '2024-04-25 08:05:00'),
    ('3', 'sku_index', '2024-04-25 08:10:00');

INSERT INTO TABLE HHDtest.dim_user_info (id,name,create_time)
VALUES
    ('1','张三',"2024-04-25 06:00:00"),
    ('2','李四',"2024-04-24 07:03:00"),
    ('3','赵大',"2024-04-22 17:23:01");
```

## 1.

> 页面统计
>
> 需求：
> 字段                类型              备注
> `dt`               STRING           '统计日期'(分区列),
> `recent_days`      BIGINT           '日期范围',
> `uv_count`         BIGINT           '访客人数',
> `avg_duration_sec` BIGINT           '平均停留时长，单位为秒',
> `avg_page_count`   BIGINT           '平均浏览页面数',
> `sv_count`         BIGINT           '会话总数',
> `bounce_rate`      DECIMAL(16, 2)   '跳出率'
>  只考虑最近1天，即范围为今天和昨天
>
> 结果存入HHDtest.ads_traffic_stats_by_channel表

## 2.

> 找到用户每天第一次访问的页面、倒数第二次访问的页面和访问最多的页面
>
> 将结果存入 HHDtest.ads_user_FirstAndSecondToLastAndMaxPage
>
> 字段           类型          说明
>
> user_id      string        用户id
>
> user_name    String        用户姓名
>
> first_page   String        第一次访问的页面名
>
> s_to_last    String        倒数第二次访问的页面名(如果只有一个访问，则返回该访问）
>
> max_the_page String        访问最多的页面名(如果有多个最多，则返回一个集合，使用 ,分隔）
>
> dt         String        日期(分区列）

## 3.

> 统计2024-04-26起前3天、七天、十四天登录的用户，并统计这些天的平均用户登录率 以及 星期几最多用户登录，范围记录中只有一次登录的用户视为范围流失用户，统计流失用户的数量
>
> 将结果存入 HHDtest.login3and7and14day
>
> 字段               类型          说明
>
> days               INT           天数
>
> date_range          STRING        范围
>
> max_login_in_week  STRING        星期几最多用户,如果有多个并列存在，则取集合，使用,分割
>
> lost_users         STRING           范围流失用户数量
>
> lost_user_rate     STRING        范围流失率(保留两位小数，xx.xx%)
>
> range_login_rate     STRING      登录率(保留两位小数，xx.xx%)

# 二

## sql准备

使用比赛数据即可

## 1

> ```scala
> /**
>  * 题1：根据dwd层表统计每个省份、每个地区、每个月下单的数量和下单的总金额，
>  * 并将结果存入MySQL数据库shtd_result的t1表中。
>  *
>  * 表结构如下：
>  * year int,
>  * month int,
>  * province_id int,
>  * province_name text,
>  * region_id int,
>  * region_name text,
>  * total_amount double,
>  * total_count int
>  */
> ```

## 2

> ```scala
>   /**
>    * 题2：统计dwd层中每个用户每月的累计订单金额存入MySQL的shtd_result.t2表。按照金额从高到低排序，取前10名。
>    *
>    * 表结构如下
>    * user_id int,
>    * user_name text 用户姓名
>    * total_amount double
>    * year int
>    * month int
>    */
> ```

## 3

> ```scala
>   /**
>    * 题3：计算dwd层中每个商品(sku_id)每月的销售总量和销售总金额，不考虑年份，对每月金额进行降序排序，形成sequence字段，
>    * 金额需要四舍五入并且不保留小数，存入MySQL的shtd_result.t3表，
>    * sequence从高到低排序，取前3月的数据，将截图和sql。
>    *
>    * 表结构如下：
>    * month int,
>    * sku_id int,
>    * sku_name text,
>    * total_amount int,
>    * total_count int,
>    * sequence int
>    */
> ```

## 4

> ```scala
>   /**
>    * 题4：计算dwd表中生日在2005年4月26日最近7天内（包含2005-04-26）用户的订单数量和订单总金额，以及生日每天为单位中，销售最多的商品，
>    * 将结果存入MySQL的shtd_store.t4表中，按照生日日期取顺序、订单金额取倒序，取前2条数据。
>    *
>    * 表结构如下：
>    * birthday text yyyy-MM-dd,
>    * user_id int,
>    * user_name text,
>    * total_count int,
>    * total_amount double,
>    * hi_sku_id,
>    * hi_sku_name
>    */
> ```

## 5

> ```scala
>   /**
>    * 根据dwd层表实现，统计全订单的运费在全订单金额中的占比，并将每个订单中运费和金额的占比与全订单的占比进行比较，
>    * 当单个订单运费占比高于全订单运费占比的20倍时，记为"大件"，否则记为"小件"。
>    * 将结果存入MySQL中的shtd_result.t5表中，查询大件的订单，并且以占比降序进行查询前5条，查询小件的订单，
>    * 并且以占比降序进行查询前5条，将两个结果的截图和sql语句
>    *
>    * 表结构如下：
>    * order_id int,
>    * allorders text 四舍五入保留两位小数: 10.00%,
>    * orders text 四舍五入保留两位小数: 10.00%,
>    * imm text
>    */
> ```

## 6

> ```scala
>   /**
>    * 根据dwd层，计算每个用户购买的商品的次数和总金额，存入MySQL的shtd_result.t6表中。
>    * 按照用户id、商品id、购买总金额均为降序排序查询
>    *
>    * 表结构如下：
>    * user_id int,
>    * user_name text,
>    * sku_id int,
>    * sku_name text,
>    * sku_total_amount double,
>    * sku_total_count int
>    */
> ```

## 7

> ```scala
>   /**
>    * 每个用户的第一次购买时间和最后一次购买时间，并计算两次购买的时间间隔(单位为日),结果存入mysql的shtd_result.t7表中
>    * 按照时间间隔降序查询
>    * 表结构如下：
>    * user_id int,
>    * user_name text,
>    * first_pay_time text,
>    * last_pay_time text,
>    * how_long_time text
>    */
> ```

## 8

> ```scala
>   /**
>    * 根据dwd层数据计算每个订单的销售额增长率，以及每个月全网的销售额增长率，将结果存入MySQL的shtd_result.t8表中，
>    * 按照订单增长率取前5条数据
>    * 字段如下：
>    * order_id int,
>    * zzl text 单个订单增长率,
>    * allzzl text 全网增长率,
>    * year int,
>    * month int
>    */
> ```

## 9

> ```scala
>   /**
>    * 题9：计算dwd层数据中，以全网最晚下单时间为中心，往前推7天(包含最晚下单当天)，计算每个用户的生命周期价值，并将生命周期的长度获取到，
>    * 生命周期长度是指第一次下单和最后一次下单之间的天数，
>    * 当用户的生命周期小于5天大于等于3天且下单量大于等于2且订单金额大于500小于等于1000时，记作留存可能中等、获取成本中等，
>    * 生命周期小于3天且下单量大于3且订单金额大于1000时，记作留存可能高、获取成本低，
>    * 当生命周期大于5天且订单量小于2且订单金额小于等于500时，记作留存可能低，获取成本高，其余情况记作待定
>    * 目的是能够将资源倾向于更有可能留存的用户
>    *
>    * 表结构如下：
>    * user_id int,
>    * user_name text,
>    * smzq int 生命周期长度,
>    * order_count int 订单量,
>    * total_amount double 生命周期总金额，四舍五入取2位小数,
>    * LTV text 留存可能性获取成本情况
>    */
> ```

## 10

> ```scala
>   /**
>    * 题10：根据dwd层计算每个省份每个月的订单数量和总金额的变化趋势，并预测接下来的一个月趋势，当最大时间前两个月或以上都为上涨时，下一个月也预计为
>    * 上涨，当最大时间的前两个月或以上都为下降时，下一个月也预计为下降，当只有一个月上涨或下降时，下一个月预计持平
>    *
>    * 表结构如下：
>    * year int,
>    * month int,
>    * province_id int,
>    * province_name text,
>    * total_amount double.
>    * total_count int,
>    * bhqs text
>    */
> ```

## 11

> ```scala
>   /**
>    * 假设当前的每个商品的库存都是8000，根据dwd层表求出各商品的滞销率,当滞销率小于0时，提醒补货，其他情况为空（空表示，不用Null表示）
>    * 将结果存入ClickHouse的shtd_result.t1表中
>    * 表结构如下：
>    * sku_id int,
>    * sku_name String,
>    * UnsoldRate String 滞销率 四舍五入保留两位小数,
>    * RemainingInventory int 剩余库存,
>    * identifying String
>    */
> ```

## 12

> ```scala
>   /**
>    * 题12：对于dwd层，使用滑动窗口计算每个商品的销售额在最近7天内的平均值，滑动步长为1天，将结果存入ClickHouse的shtd_store.t12表
>    *
>    * 表结构：
>    * time String 当前时间 yyyy-MM-dd，
>    * sku_id int,
>    * avg_amount double 平均销售额
>    */
> ```

## 13

> ```scala
>   /**
>    * 题13：根据hive的dwd层，计算每个用户每三次订单的平均订单金额，将结果存入ClickHouse的shtd_result.t3表中
>    *
>    * 表结构如下：
>    * user_id int,
>    * user_name String,
>    * time_to_time String 时间区间，yyyyMMddHHmmss_yyyyMMddHHmmss
>    * avg_amount double
>    */
> ```

## 14

> ```scala
>   /**
>    * 题14：根据dwd层数据，使用滚动窗口计算每个用户每个订单的累计订单数量，以及每增加一个订单时的平均订单金额增长率,
>    * 将结果存入ClickHouse的shtd_result.t4表中
>    *
>    * 表结构如下：
>    * order_id int,
>    * user_id int,
>    * user_name String,
>    * total_count int,
>    * AmountGrowthRate String 保留两位小数
>    */
> ```

## 15

> ```scala
>   /**
>    * 题15：基于dwd层，使用滚动窗口计算每个用户最近五次购买的平均折扣率，将结果存入ClickHouse的shtd_result.t5表中
>    *
>    * 数据结构如下：
>    * user_id int,
>    * user_name String,
>    * avg_discount_rate String 四舍五入保留两位小数百分比
>    */
> ```

## 16

> ```scala
>   /**
>    * 题16：基于dwd层，使用滑动窗口计算每个用户最近7天内购买商品种类的变化次数。将结果写入ClickHouse的shtd_result.t6表中
>    *
>    * user_id int,
>    * user_name String,
>    * time_to_time String 时间区间,格式为yyyyMMdd-yyyyMMdd,
>    * num_of_changes int 种类变化次数
>    */
> ```

## 17

> ```scala
>   /**
>    * 根据dwd层，统计最多用户购买的时间段，6-12为上午，12-18为下午，18-次日6为晚上，将结果存入
>    * ClickHouse的shtd_result.t7中
>    *
>    * 字段如下：
>    * how_time String 时间段，早上、下午、晚上
>    * pay_cnt int 购买次数
>    * time_to_time String 时间区间yyyyMMddHH_yyyyMMddHH
>    */
> ```

## 18

> ```scala
>   /**
>    * 根据dwd层数据计算每个商品在总订单中的占比，将结果存入ClickHouse的shtd_result.t8表中
>    *
>    * 表结构如下：
>    * sku_id int,
>    * sku_name String,
>    * proportion String 占比%，四舍五入保留两位小数
>    */
> ```

## 19

> ```scala
> /**
>    * 计算dwd层订单详细信息表中每个用户的复购间隔时间的中位数，将结果存入ClickHouse中的shtd_result.t9表
>    *
>    * 表结构如下：
>    * user_id int,
>    * user_name String,
>    * time_median double 复购间隔时间中位数
>    */
> ```

## 20

> ```scala
>   /**
>    * 根据dwd层实现计算订单信息表中每个用户的订单金额在总订单金额的百分位排名，将结果写入Clickhouse的表shtd_result.t10中
>    *
>    * 表结构如下：
>    * user_id int,
>    * user_name String,
>    * ranking String 排名,不进行四舍五入保留两位小数%
>    */
> ```

## 21

> ```scala
>   /**
>    * 根据dwd层计算订单详细信息表中每个商品的购买频次，购买频次为每个商品被购买的次数除以不同用户购买该商品的总数
>    * 将结果写入hive的t_test.t1表中
>    * 表结构如下
>    * sku_id int,
>    * sku_name string,
>    * PurchaseFrequency double
>    */
> ```

音阶/Bigdata练习题

简介

发行版

贡献者

近期动态

音阶/Bigdata练习题 .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

音阶/Bigdata练习题