数据中台数据中台
申请试用
实时开发平台
实时开发平台(StreamWorks),基于Apache Flink构建的高性能、一站式实时数仓开发平台,包含实时数据采集、实时开发/调试、实时运维监控等功能,提供面向海量数据的秒级分析服务,助力实时数仓建设、企业数据应用实时化。
产品优势
产品功能
应用场景
产品架构
客户案例
产品动态
产品优势
流批一体
一个实时任务即可实现全/增量数据采集开发的自动切换和无缝衔接,降低开发成本的同时又能满足多种数据处理场景
数据还原
实时采集时自动还原上游数据和数据结构,缩短实时处理链路,有效减少实时任务的失败频率和数据清洗成本
湖仓兼容
支持数据的实时入湖、入仓,为下游数据分析提供更近实时的数据基础,极速响应业务需求
实时全链路
平台集成Kafka管理,并且覆盖实时采集、实时开发、实时运维全流程链路,一站式满足实时计算需求
产品功能
实时采集
基于袋鼠云自研的分布式数据同步/计算框架Chunjun,支持基于CDC日志变更、JBDC间隔轮询两种方式,实现同构/异构数据源之间的实时数据还原和实时数据采集
数据开发与调试
强大的数据开发能力,支持FlinkSQL/Jar/PyFlink等任务类型,同时支持代码本地调试、截流调试,自动语法检查,任务版本管理,任务导入/导出式发布等多种能力
企业级运维
支持吞吐量、脏数据、数据延迟等丰富的实时Metric,同时支持自定义Metric,提供自动启停策略配置,节约计算资源。具备FlinkSQL血缘解析能力,构建完整的实时数仓全链路血缘,满足企业级安全可靠的运维需求
Kafka消息管理
Kafka作为实时计算链路中不可或缺的一部分,平台支持对接、管理Kafka集群。提供Topic管理、Topic Metric查看、分区管理、Consumer管理、数据采样等功能,提供一体化的实时计算解决方案
应用场景
场景描述
海量数据实时处理及高并发实时入仓,协助企业建立数字化运营体系,为经营决策提供实时数据支持,满足企业运营中对于数据时效性越来越高的要求
产品架构
产品动态
此刻起,和袋鼠云一起让数据产生更大价值