【华为云】实时流计算服务 CS

实时流计算服务（Cloud Stream Service, 简称CS）提供实时处理流式大数据的全栈能力, 简单易用, 即时执行Stream SQL或自定义作业。无需关心计算集群, 无需学习编程技能。完全兼容Apache Flink和Spark API。

产品优势
简单易用
在线SQL编辑平台编写Stream SQL，定义数据流入、数据处理、数据流出，快速便捷实现业务逻辑；用户无需关心计算集群, 无需学习编程技能，降低流数据分

析门槛

独享集群
全托管模式，自动弹性伸缩，用户完全不感知计算集群。提供共享集群和独享集群两种模式，独享集群与其他租户和共享集群完全物理隔离，并支持配额限制管

理

按需计费
按资源使用量计费，用多少算多少，定价单位是CU(Compute Unit，1CU=1核CPU+4G内存)，用户选定CU数，按时长计费

高吞吐低时延
采用Apache Flink的Dataflow模型，完全的实时计算框架。采用高性能计算资源，从用户自建的Kafka、MRS-Kafka、DMS-Kafka消费数据，单SPU每秒吞吐1千~2

万条消息，不同场景的吞吐量有差异

主要功能

StreamingML
提供多种流式机器学习方法对数据进行实时分析与预测，用户仅需编写SQL调用相关函数便可实现数据统计，异常检测，实时聚类，时间序列分析等场景

地理位置分析
提供地理位置分析函数对地理空间数据进行实时分析，用户仅需编写SQL便可实现例如偏航检测，电子围栏等地理分析场景

CEP SQL
提供基于Match Recognize的模式匹配检测，帮助业务人员使用SQL实现基于复杂事件规则的异常检测业务。典型应用场景如欺诈检测、车辆异常行为检测、工业

设备异常运行状态检测等

可视化
提供多种图表类型实时展示作业数据输出，用户可以通过API网关服务自由访问作业数据，接入自定义工作流中

应用场景

实时流分析场景

实时流分析场景

提供易用、低时延、高吞吐的实时流分析服务。支持Stream SQL和用户自定义作业做流分析

优势

易用
在线编辑Stream SQL，丰富的SQL函数满足复杂业务需要

完全托管
用户完全不感知计算集群，聚焦流分析本身

按需计费
作业选定SPU资源量，按时长计费，精确到秒

建议搭配使用
OBS DIS

物联网IoT场景

物联网IoT场景

物联网设备或边缘设备，上传数据到数据接入服务（DIS）或者其他云存储服务，Cloud Stream直接从DIS读取数据，实时分析数据流（故障检测、数据清洗、统

计分析、指标预警等等），实时把流分析结果持久化或推送告警通知

优势

丰富的IoT SQL函数
区域检测函数、偏航检测函数、相对位置判断等常用的IoT函数

高吞吐低时延
使用Apache Flink执行引擎 ，完全的实时计算框架

安全隔离
租户之间完全隔离，确保数据安全

建议搭配使用
OBS DIS

功能描述

丰富的StreamSQL在线分析能力

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

低时延高吞吐

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

安全可靠

租户安全机制保障，确保作业安全运行

分布式实时计算

支持大规模集群计算，集群弹性伸缩，节省成本

帮助文档