Beam适配GaussDB开源开发任务
1 背景介绍
开源for Huawei(参考:https://developer.huaweicloud.com/programs/opensource/contributing/) 通过和公司、高校、社区的开发者合作,完成鲲鹏、昇腾、欧拉、鸿蒙、高斯、云服务等与开源软件的适配开发,帮助繁荣Huawei的基础生态,同时让开源软件能够更加简单、高效的运行于华为云上。
开始之前,开发者可以下载 开源for Huawei Wiki(参考:https://gitcode.com/HuaweiCloudDeveloper/OpenSourceForHuaweiWiki/overview) 了解详细的开发步骤,技术准备,以及开发过程需要的各种资源。
1 需求分析
1.1 项目影响力
随着分布式数据处理不断发展,业界涌现出越来越多的分布式数据处理框架,从最早的hadoop Mapreduce到apache spark、apache Storm、以及更近的Apache Flink、Apache Apex等。新的分布式处理框架可能带来更高性能,更强大功能,更低的延迟等,但用户切换到新的分布式处理框架的代价也非常大;需要学习一个新的数据处理框架,并重写所有的业务逻辑。解决这个问题的思路的包括两部分,首先,需要一个编程范式,能够统一规范分布式数据处理的需求,例如统一的批处理和流处理的需求。其次生成的分布式数据处理任务应该能够在各个分布式引擎上执行,用户可以自由切换引擎和执行环境。Apache Beam 正是为看解决以上问题而提出的。
项目数据:Fork 4.2k,Star 7.8k,Contributors 1220+
主要开发语言
• Java 66.1%
• Python 17.1%
star历史(https://star-history.com/):

1.2 任务目的和范围
本任务的主要目的是让Beam支持华为云 GuassDB数据库,拓展GuassDB数据库的影响力,让Beam的用户使用华为云服务时能够顺利对接GuassDB数据库。
l 适配任务清单
| 生态 | 生态细类 | 是否需要验证 | 验证逻辑说明 | 是否需要适配 | 适配场景说明 | 
| 昇腾生态 | 指令 | 否 | 使用昇腾处理器运行应用。 | 否 | 使用昇腾指令实现适配逻辑。 | 
| CANN | 否 | 应用功能依赖于CANN运行。 | 否 | 使用CANN实现适配逻辑。 | |
| MindSpore | 否 | 应用功能依赖于MindSpore运行。 | 否 | 使用MindSpore实现适配逻辑。 | |
| 鲲鹏生态 | 指令 | 是 | 使用鲲鹏处理器运行应用。 | 否 | 使用鲲鹏指令实现适配逻辑。 | 
| Euler | 是 | 使用Euler系统运行应用。 | 否 | 使用Euler系统调用实现适配逻辑。 | |
| 数据库生态 | GaussDB | 是 | 使用GaussDB功能。 | 是 | 使用GaussDB的驱动和SQL实现适配逻辑。 | 
| 
 | GaussDB(DWS) | 否 | 使用GaussDB(DWS)功能。 | 否 | 使用GaussDB(DWS)的驱动和SQL实现适配逻辑。 | 
| 存储生态 | OBS | 否 | 使用OBS功能。 | 否 | 基于OBS API访问实现适配逻辑。 | 
| 鸿蒙生态 | HarmonyOS | 否 | 使用HarmonyOS系统运行应用。 | 否 | 使用HarmonyOS系统调用实现适配逻辑。 | 
2 工作量评估和任务分解
2.1 工作量评估
| 任务 | 人/天 | 
| 基于华为云ECS完成Beam安装和部署 | 2 | 
| 完成GaussDB适配功能设计和开发 | 5 | 
| 完成DEMO验证 
 | 1 | 
| 输出开发资料和博客 | 1 | 
| 代码推送上游社区和发布版本 | 2 | 
| 总计 | 11人天 | 
3 任务分解
3.1 基于华为云ECS完成Beam的安装和部署
DEMO的简单部署图如下:

Beam系统架构图:

3.2 完成GaussDB数据库适配功能设计和开发
参考现有Apache Beam架构,完成2个功能点的分析和适配工作。
1.在GitCode完成项目Fork,并完成GaussDB数据库适配需要的脚本和代码开发(包括Apache Bean从GaussDB读取数据和写数据)
2.提供Beam镜像,使用该镜像,能够对接GaussDB数据库
参考:
Apache Beam github源代码连接数据案例
https://github.com/apache/beam/tree/master/it/jdbc/src/main/java/org/apache/beam/it/jdbc
3.3 DEMO部署和验证
根据DEMO设计,完成演示功能开发和部署。要求使用CCE容器(Euler镜像)进行部署;
Beam任务执行从GaussDB读取数据以及写入数据。
3.4 在华为云开发者论坛输出博客
访问华为云开发者论坛(参考:https://bbs.huaweicloud.com/blogs)发表博客,介绍完成这些任务的过程和心得。
内容包括不限于如下内容:
- 开源for Huawei的背景
- 开源软件的功能介绍
- 开发适配过程及碰到和解决的问题
- DEMO设计、开发、部署过程
- 代码推送开源社区及互动过程
博客打上如下标签:
- 开源(必选)
- 开发者(必选)
- GaussDB数据库(可选)
- 云数据库 GaussDB(可选)
- 鲲鹏(可选)
- 昇腾(可选)
- 鸿蒙(可选)
3.5 代码推送上游社区
将代码合并到Beam官网主干代码;更新Beam官网资料,包括版本说明、开发指南等
4 验收材料
| 验收细则 | 评分说明 | 是否为验收必选项 | 结果(通过/不通过) | 开发者举证 | 
| 功能开发:完成与华为三大根技术生态(鲲鹏云、昇腾云、鸿蒙)适配的功能开发 | 完成GaussDB数据库适配功能开发。举证提供PR链接。 | 是 | ||
| 代码质量:适配华为三大根技术生态的代码质量经过工具检测达标 | 推送给开源社区的代码符合开源社区关于代码风格、功能、自动化测试等要求。 | 是 | ||
| 提供相关文档,比如部署文档、使用文档、配置文档等 | 根据社区要求,完善相关的开发指南和部署指导 | 否 | ||
| 合入到开源项目主仓:代码推送上游社区 | 代码合并到当前主干分支。举证提供代码仓库链接。 | 是 | ||
| Deomo设计&开发:完成功能演示Demo的开发 | 举证提供DEMO仓库地址和DEMO开发提交记录。 | 是 | ||
| Demo部署&验证:完成功能演示DEMO基于华为云鲲鹏环境的部署和功能验证 | 提供DEMO部署验证结果的关键截图进行举证。提供DEMO运行环境和资源的规格清单。 | 是 | ||
| 发布博客:发布博客介绍适配心得。 | 提供博客的地址。 | 是 | ||
| 制作单机版无高危开源镜像。 | 上架云商店。 | 否 | ||
| 单机版镜像上架时支持模板部署。 | 否 | |||
| 制作集群版无高危开源镜像 | 上架云商店。 | 否 | ||
| 集群版镜像上架时支持模板部署 | 否 | 
5 参考资料
- 开源for Huawei介绍、环境搭建、示例项目、开发和部署指南:https://gitcode.com/HuaweiCloudDeveloper/OpenSourceForHuaweiWiki/overview
- 点赞
- 收藏
- 关注作者
 
             
           
评论(0)