博客湖仓一体电商项目（八）：业务实现之编写写入ODS层业务代码

湖仓一体电商项目（八）：业务实现之编写写入ODS层业务代码

数栈君发表于 2023-04-13 18:16 467 0

一、代码编写

DIM层业务代码与第一个业务处理Kafka topic “KAFKA-DIM-TOPIC” 数据到HBase代码完全一直，所以这里直接复用第一个业务中的DIM层业务代码“DimDataToHBase.scala”即可。

二、代码测试

执行代码“DimDataToHBase.scala”之前首先需要启动HDFS、HBase，代码中设置读取Kafka数据从头开始读取，然后执行代码，代码执行完成后可以进入phoenix中查看对应的结果：

# 在node4节点上启动phoenix
[root@node4 ~]# cd /software/apache-phoenix-5.0.0-HBase-2.0-bin/bin
[root@node4 bin]# ./sqlline.py

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/article/50c7d9a10159ebc058bf21c8a4654145..jpg

本文系转载，版权归原作者所有，如若侵权请联系我们进行删除！

140页深度干货，囊括15个典型成功案例，覆盖金融、集团、政务、制造、港口5大行业，全书从方法论到实践全面解码数据治理，开辟数据治理新范式，丰富内容可免费获取！

免费获取链接：https://fs80.cn/4w2atu

想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：https://www.dtstack.com/?src=bbs

同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：https://github.com/DTStack