本教程將指導您如何在Dataphin中基於Ververica Flink完成即時研發並進行可視化分析。以協助您快速瞭解Dataphin進行即時研發的基本流程。
背景資訊
某公司的訂單系統使用MySQL作為儲存資料庫，其中的oms_order為儲存訂單的表。現在要開始設計一個營銷活動，在活動期間需要即時地統計每個產品類型的銷售數量，用於快速地支援活動方案調整。
以下為資料流向的示意圖：
訂單系統MySQL的資料通過Ververica Flink任務進行Realtime Compute，即時匯總各產品類型的銷售數量並寫入另一個用於OLAP分析的MySQL資料庫。
通過BI工具（Quick BI等）讀取MySQL中的資料，進行可視化分析。
流程指引
使用Dataphin進行即時研發的基本流程如下：
主流程 | 描述 | 操作指導 |
準備工作 | 使用Dataphin進行即時研發前您需完成相關雲資源的準備。雲資源準備包括阿里雲帳號資源準備、Dataphin開通與AccessKey配置、Ververica Flink計算源的開通與配置、Quick BI的開通（非必選）以及資料來源的準備。 | |
專案和計算源 | 即時專案是開發即時任務的基本單元，可用於綁定Ververica Flink計算源進行即時研發。 | |
即時元表 | 元表是通過資料管理的跨儲存類型表，開發過程中所用到的輸入表、輸出表、維表可以通過建立元表進行建立和管理。 | |
即時任務 | 通過建立Flink_SQL流任務，讀取或寫入元表映射的資料來源中的表資料。 | |
任務營運 | 完成即時研發後，任務提交至營運中心，可以對即時任務進行啟動、停止、查看任務日誌、任務運行指標、配置監控警示等營運操作。 | |
可視化分析 | 非必選。啟動即時執行個體後，即時讀取來源表資料經Ververica Flink計算和處理後即時寫入到結果表中。可以使用BI工具（例如，Quick BI等）對結果表中的資料進行可視化分析。 |