實時流計算服務(wù) （Cloud Stream Service,簡稱CS）提供實時處理流式 大數(shù)據(jù) 的全棧能力,簡單易用,即時執(zhí)行Stream SQL或自定義作業(yè)。無需關(guān)心計算集群,無需學(xué)習(xí)編程技能。完全兼容Apache Flink和Spark API
產(chǎn)品優(yōu)勢
簡單易用
在線SQL編輯平臺編寫Stream SQL，定義數(shù)據(jù)流入、數(shù)據(jù)處理、數(shù)據(jù)流出，快速便捷實現(xiàn)業(yè)務(wù)邏輯；用戶無需關(guān)心計算集群,無需學(xué)習(xí)編程技能，降低流數(shù)據(jù)分析門檻。
獨享集群
全托管模式，自動 彈性伸縮 ，用戶完全不感知計算集群。提供共享集群和獨享集群兩種模式，獨享集群與其他租戶和共享集群完全物理隔離，并支持配額限制管理。
按需計費
按資源使用量計費，用多少算多少， 定價 單位是CU(Compute Unit，1CU=1核CPU+4G內(nèi)存)，用戶選定CU數(shù)，按時長計費。
高吞吐低時延
采用Apache Flink的Dataflow模型，完全的實時計算框架。采用高性能計算資源，從用戶自建的Kafka、MRS-Kafka、DMS-Kafka消費數(shù)據(jù)，單SPU每秒吞吐1千~2萬條消息，不同場景的吞吐量有差異。
應(yīng)用場景
實時流分析場景
提供易用、低時延、高吞吐的實時流分析服務(wù)。支持Stream SQL和用戶自定義作業(yè)做流分析。
優(yōu)勢
易用：在線編輯Stream SQL，豐富的SQL函數(shù)滿足復(fù)雜業(yè)務(wù)需要。
完全托管：用戶完全不感知計算集群，聚焦流分析本身。
按需計費：作業(yè)選定SPU資源量，按時長計費，精確到秒。
物聯(lián)網(wǎng)IoT場景
物聯(lián)網(wǎng)設(shè)備或邊緣設(shè)備，上傳數(shù)據(jù)到 數(shù)據(jù)接入服務(wù) （DIS）或者其他 云存儲 服務(wù)，Cloud Stream直接從DIS讀取數(shù)據(jù)，實時分析數(shù)據(jù)流（故障檢測、數(shù)據(jù)清洗、統(tǒng)計分析、指標(biāo)預(yù)警等等），實時把流分析結(jié)果持久化或推送告警通知。
優(yōu)勢
豐富的IoT SQL函數(shù)：區(qū)域檢測函數(shù)、偏航檢測函數(shù)、相對位置判斷等常用的IoT函數(shù)。
高吞吐低時延：使用Apache Flink執(zhí)行引擎，完全的實時計算框架。
安全隔離：租戶之間完全隔離，確保 數(shù)據(jù)安全 。
