基于云原生开源消息中间件 RocketMQ 的轻量级流计算创新应用

命题企业:阿里云计算有限公司
企业介绍:
阿里云计算有限公司创立于2009年,致力于成为“数字经济时代的基础设施”。公司以在线公共服务的方式,为全球200多个国家和地区的企业、开发者和政府机构提供安全、可靠的计算和数据处理能力,让计算和人工智能成为普惠科技。经过十年多的自主研发与创新,阿里云已成为全球领先的云计算及人工智能科技公司。
命题内容及答题要求
【命题背景】 作为数据处理领域最火的方向,实时计算已经成为当前众多开发者追随的方向,同时人们也在积极探索,如何将在线业务与数据的实时计算更好的结合起来,在避免转储的同时尽力提升数据就近计算的时效性。RocketMQ 作为云原生的消息事件流融合处理平台,被广泛用在国内的各头部互联网、金融等企业,成为在线业务消息领域的标准,伴随着RocketMQ 5.0 的发布,轻量级的流计算引擎 RocketMQ Streams 应运而生,相比于其他的实时计算框架,RocketMQ Streams 适合大数据、高过滤、轻窗口计算的场景,核心打造轻资源,高性能优势,在资源敏感场景中有很大优势,最低 1core,1g 可部署。本题目要求基于RocketMQ 及 RocketMQ Streams等开源产品,进行轻量级实时计算应用/解决方案开发或者创新实践,助力 RocketMQ/ RocketMQ Streams 在各领域落地。 【命题内容】 参赛者可以从以下方向/领域进行选择性探索,更鼓励参赛者发挥想象做更多领域的探索与创新: 1. RocketMQ-Streams 与 边缘计算的结合,通过rocketmq-mqtt 实时接收边缘端数据进行实时计算,ETL 处理,指令下发。 2. RocketMQ-Streams 与真实业务结合,比如在电商场景中,基于RocketMQ 中的交易消息数据,实时统计当前成交量。 3. RocketMQ-Streams 与微服务业务日志结合,通过对日志进行过滤采集某些指标进行计算,来对当前服务的Metrics 数据结果输出及对异常行为进行实时告警。 【答题要求】: 1. 边界要求:基于 RocketMQ 生态的开源产品,符合轻量级实时计算场景; 2. 交付要求:参赛者需提供设计文档及最终代码,具备演示能力 3. 需提前学习的技术文档或视频:基于实际作品开发需求,熟悉 Apache RocketMQ 架构以及 RocketMQ-Streams 框架。 【技术支持社区】 https://developer.aliyun.com/learning/topic/internetplus?utm_content=g_1000338515