需求:求独立访客数

前奏准备

打开Sugar

实时数仓(三十九)ADS层-渠道日活需求 - 图1

实时数仓(三十九)ADS层-渠道日活需求 - 图2

实时数仓(三十九)ADS层-渠道日活需求 - 图3

在静态JSON中找到其数据格式

  1. {
  2. "status": 0,
  3. "msg": "",
  4. "data": {
  5. "categories": [
  6. "苹果",
  7. "三星",
  8. "华为",
  9. "oppo",
  10. "vivo",
  11. "小米86"
  12. ],
  13. "series": [
  14. {
  15. "name": "手机品牌",
  16. "data": [
  17. 5583,
  18. 6956,
  19. 5576,
  20. 7942,
  21. 5269,
  22. 5255
  23. ]
  24. }
  25. ]
  26. }
  27. }

SQL语句测试

  1. select ch,sum(uv_ct) uv,sum(uj_ct) uj from dws_traffic_vc_ch_ar_is_new_page_view_window where toYYYYMMDD(stt) = 20220906 group by ch order by uv desc;

在ClickHouse中写入

实时数仓(三十九)ADS层-渠道日活需求 - 图4

把ch 替换为categories 中的内容,uv替换为data中的内容。

代码编写

UvMapper接口

https://gitee.com/luan_hao/gmall-flink/blob/master/gmall-publisher/src/main/java/com/apache/gmall/mapper/UvMapper.java

UvService接口

https://gitee.com/luan_hao/gmall-flink/blob/master/gmall-publisher/src/main/java/com/apache/gmall/service/UvService.java

SugarContrller类

https://gitee.com/luan_hao/gmall-flink/commit/e465b1a85499d15edb41e885c7abb2b898e2bee8

UvServiceImpl类

https://gitee.com/luan_hao/gmall-flink/blob/master/gmall-publisher/src/main/java/com/apache/gmall/service/impl/UvServiceImpl.java

启动SpringBoot程序

测试

简单测试

实时数仓(三十九)ADS层-渠道日活需求 - 图5

开启内网工具

实时数仓(三十九)ADS层-渠道日活需求 - 图6

在Sugar上测试,使用内网穿透,将网站复制到Sugar API 拉取中

实时数仓(三十九)ADS层-渠道日活需求 - 图7

可视化图表

开启 https://www.yuque.com/manyanshanhe/duxfre/dnuyat#aWAtM 的内容 与 SpringBoot 主程序

实时数仓(三十九)ADS层-渠道日活需求 - 图8