華為云計算 云知識 實時流計算服務
實時流計算服務

實時流計算服務 (Cloud Stream Service,簡稱CS)提供實時處理流式 大數據 的全棧能力,簡單易用,即時執(zhí)行Stream SQL或自定義作業(yè)。無需關心計算集群,無需學習編程技能。完全兼容Apache Flink和Spark API

產品優(yōu)勢

簡單易用

在線SQL編輯平臺編寫Stream SQL,定義數據流入、數據處理、數據流出,快速便捷實現(xiàn)業(yè)務邏輯;用戶無需關心計算集群,無需學習編程技能,降低流數據分析門檻。

獨享集群

全托管模式,自動 彈性伸縮 ,用戶完全不感知計算集群。提供共享集群和獨享集群兩種模式,獨享集群與其他租戶和共享集群完全物理隔離,并支持配額限制管理。

按需計費

按資源使用量計費,用多少算多少, 定價 單位是CU(Compute Unit,1CU=1核CPU+4G內存),用戶選定CU數,按時長計費。

高吞吐低時延

采用Apache Flink的Dataflow模型,完全的實時計算框架。采用高性能計算資源,從用戶自建的Kafka、MRS-Kafka、DMS-Kafka消費數據,單SPU每秒吞吐1千~2萬條消息,不同場景的吞吐量有差異。

應用場景

實時流分析場景

提供易用、低時延、高吞吐的實時流分析服務。支持Stream SQL和用戶自定義作業(yè)做流分析。

優(yōu)勢

易用:在線編輯Stream SQL,豐富的SQL函數滿足復雜業(yè)務需要。

完全托管:用戶完全不感知計算集群,聚焦流分析本身。

按需計費:作業(yè)選定SPU資源量,按時長計費,精確到秒。

物聯(lián)網IoT場景

物聯(lián)網設備或邊緣設備,上傳數據到 數據接入服務 (DIS)或者其他 云存儲 服務,Cloud Stream直接從DIS讀取數據,實時分析數據流(故障檢測、數據清洗、統(tǒng)計分析、指標預警等等),實時把流分析結果持久化或推送告警通知。

優(yōu)勢

豐富的IoT SQL函數:區(qū)域檢測函數、偏航檢測函數、相對位置判斷等常用的IoT函數。

高吞吐低時延:使用Apache Flink執(zhí)行引擎,完全的實時計算框架。

安全隔離:租戶之間完全隔離,確保 數據安全 。