.jpg)
.jpg)
.jpg)
.jpg)
实时流计算服务 （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万条消息，不同场景的吞吐量有差异。
应用场景
实时流分析场景
提供易用、低时延、高吞吐的实时流分析服务。支持Stream SQL和用户自定义作业做流分析。
优势
易用：在线编辑Stream SQL，丰富的SQL函数满足复杂业务需要。
完全托管：用户完全不感知计算集群，聚焦流分析本身。
按需计费：作业选定SPU资源量，按时长计费，精确到秒。
物联网IoT场景
物联网设备或边缘设备，上传数据到 数据接入服务 （DIS）或者其他 云存储 服务，Cloud Stream直接从DIS读取数据，实时分析数据流（故障检测、数据清洗、统计分析、指标预警等等），实时把流分析结果持久化或推送告警通知。
优势
丰富的IoT SQL函数：区域检测函数、偏航检测函数、相对位置判断等常用的IoT函数。
高吞吐低时延：使用Apache Flink执行引擎，完全的实时计算框架。
安全隔离：租户之间完全隔离，确保 数据安全 。
