实时流计算服务

实时流计算服务(Cloud Stream Service,简称CS),是运行在华为云上的实时流式大数据分析服务,全托管的方式使用户无需感知计算集群,只需聚焦于Stream SQL业务,即时执行作业,完全兼容Flink API。

现以申请公测资格方式免费试用,名额有限。 了解详情

产品优势

易用

在SQL编辑平台写StreamSQL,StreamSQL定义数据流入、数据处理、数据流出,快速便捷实现业务逻辑,降低流数据分析门槛。

全托管

用户完全不感知计算集群,对运行的作业可视化查看运行状态。

开箱即用

不再关心各种大数据框架,写StreamSQL,即时运行作业。

按需计费

定价单位是SPU(StreamProcessing Unit, 1 SPU = 1核 + 4G),用户选定SPU数,按照时长收费,精确到秒。

安全隔离

租户计算集群完全和其他租户物理隔离,独立的安防设置,确保计算集群的安全性。

高吞吐低时延

采用Flink的Dataflow模型,完全的实时计算框架。

产品架构

在实时业务架构中,流计算服务使用DIS服务作为数据源,用户在流计算服务中提交StreamSQL作为数据处理逻辑,处理结果输出到持久化数据存储,以供下游业务使用。

  • Source数据源
    从DIS服务中读取数据
  • 流式计算
    提供Stream SQL和Flink API两种能力,上手成本最低,使用简便
  • Sink数据输出
    分析的结果数据,实时写入DIS/OBS等服务,以供下游业务使用

应用场景

实时流分析场景

应用

实时大数据分析

场景特点

面向流数据,支持window、CEP、Join等复杂的流分析操作,毫秒级延迟;

适用场景

实时日志分析,网络流量监控,实时风险管控,实时数据统计,实时数据ETL。

物联网IOT场景

应用

物联网在线数据分析

场景特点

物联网IoT直接调用CloudStream服务API,CloudStream可以实时读取传感器信息并执行用户的分析逻辑,分析结果对接到DIS、RDS等服务用于可视化、持久化、告警或报表展示

适用场景

电梯IoT;工业IoT;共享单车;互联网汽车;智能家居。

功能描述

丰富的StreamSQL在线分析能力

支持window、join等聚合函数,用SQL表达业务逻辑,简便快捷实现业务。

低时延高吞吐

从DIS中读取数据,服务支持自然反压机制,支持高吞吐压力;毫秒级延迟,满足实时计算的业务场景。

安全可靠

租户三重安全机制保障,确保作业安全运行。

分布式实时计算

支持大规模集群计算,集群弹性伸缩,最大化节省成本。

立即注册华为云