代码编写

创建SugarContraller 类

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

创建GmvMapper接口

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

创建GmvService接口

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

创建GmvServiceImpl类

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

配置主程序中的注解

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

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

实时数仓(三十八)ADS层-GMV需求 - 图1

测试

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

再次查看效果

实时数仓(三十八)ADS层-GMV需求 - 图2

可以频繁造数据,实时查看效果