Tablestore：Realtime ComputeFlink

背景資訊

Realtime ComputeFlink版是一套基於Apache Flink構建的一站式即時巨量資料分析平台，提供端到端亞秒級即時資料分析能力，並通過標準SQL降低了業務開發的門檻。平台內建了Table StoreTablestore連接器，用於Tablestore的資料讀寫與計算。更多資訊，請參見附錄1：Tablestore連接器。

Table Store通道服務（Tunnel Service）是基於Table Store資料介面上的全增量一體化服務。通過為資料表建立資料通道，您可以通過流式計算的方式對錶中存量和新增資料進行消費處理。

應用情境

Tablestore與Flink結合的方案可以實現如下情境需求：

• 即時資料分析與處理

  利用Tablestore作為Flink作業的資料來源，可以實現對海量結構化資料的即時採集與處理，從而協助使用者即時監控業務資料、即時分析資料趨勢，以滿足企業對市場動態快速響應的要求。

• 物聯網資料處理

  Tablestore的時序模型是專門針對時間序列資料的特點進行設計，非常適合儲存和處理物聯網裝置產生的時序資料。結合Flink的Realtime Compute能力，可以實現即時監控分析、預測性維護和智能決策，例如車輛軌跡分析、環境監測等應用。

• 金融行業風險監控

  金融機構需對交易行為進行即時監控，以識別潛在風險並採取相應措施。通過Flink對交易資料流進行即時監控，檢測異常行為（例如頻繁的大額轉賬、異地登入等），並將風險評分或異常記錄寫入Table Store，以便後續進行審計和分析。

更多Flink的應用情境，請參見應用情境。

計費說明

• Flink

  Realtime ComputeFlink的計費項目包括管控資源和計算資源。詳細計費資訊，請參見產品計費。

• Table Store

  在使用計算引擎訪問Table Store時，Table Store將會收取讀寫資料的相關費用。資料寫入後，Table Store會根據資料存放區量收取相應儲存費用。詳細計費資訊，請參見計費概述。

相關文檔

• Realtime ComputeFlink能夠將通道服務的資料通道作為流式資料的輸入，從而實現對錶格儲存資料的計算與分析。具體操作，請參見使用教程。