事件流概述
更新時間 2025-06-18 17:55:23
最近更新時間: 2025-06-18 17:55:23
分享文章
隨著越來越多的數據源持續、快速地產生數據,此類流式數據急需被系統分析和處理。事件流適用于端到端的流式數據處理場景,對源端產生的事件實時抽取、轉換和分析并加載至目標端,幫助您輕松處理流式數據。
事件流總體架構
事件流作為更輕量、實時端到端的流式事件通道,提供輕量流式數據的過濾和轉換的能力,在不同的數據倉庫之間、數據處理程序之間、數據分析和處理系統之間進行數據同步,連接不同的系統與服務。
如下圖所示,事件源與事件目標之間無需定義事件總線,事件通過事件流這個通道在源端和目標端之間進行流轉。
事件源:事件的來源,可將天翼云服務如分布式消息Kafka的業務數據作為事件流中的事件提供方。
事件過濾:事件流通過事件模式過濾事件并將事件路由到事件目標,事件模式必須和匹配的事件具有相同的結構。
事件轉換:可選擇天翼云函數計算作為事件轉換器,您可以通過編寫函數代碼對事件進行更復雜、更加定制化的處理。
事件目標:消費事件消息。
功能優勢
實時高效
事件流支持實時從事件源獲取、過濾與轉換事件,并加載至事件目標。無需定義事件總線,您可以更快地訪問事件。
輕量集成
只需在控制臺簡單創建任務或者一次調用,即可建立實時端到端的流式事件通道,避免了復雜繁瑣的操作,便于快速集成。
指標監控
事件流提供多個指標,您可以使用這些指標監控數據流的運行狀況,出現異常時及時運維,確保數據流正常運行。
節約成本
按量計費,按照數據量進行計費,不使用則不收費。