進行即時研發前您需完成相關雲資源的準備。雲資源準備包括Ververica Flink計算源、Quick BI開通(非必選)與配置以及資料來源的準備。本文將指導您完成本教程的雲資源準備工作。
步驟一:Realtime ComputeFlink版、Quick BI開通與配置
主流程 | 描述 | 操作指導 |
開通Realtime ComputeFlink版 | 購買Realtime ComputeFlink版。 | |
開通Quick BI(非必選) | 購買Quick BI。 重要 非必選,也可以使用其他BI工具進行後續的可視化分析。 | |
建立Flink專案空間 | 建立Flink專案空間,專案名稱為flink_dataphin。 重要 阿里雲Realtime ComputeFlink版使用全域的專案空間,已建立的專案空間不支援再建立。建議使用flink_dataphin_001等方式建立。 |
步驟二:準備資料來源
通過RDS建立MySQL8.0執行個體,擷取RDS執行個體ID,並在RDS控制台添加白名單,詳情請參見建立RDS MySQL執行個體。本教程中RDS資料來源名稱以flink_dataphin為例。
登入MySQL執行個體,並使用以下命令建立資料庫及資料表。
create database flink_dataphin; //建立flink_dataphin資料庫 use flink_dataphin; //使用flink_dataphin資料庫 //訂單表 CREATE TABLE `oms_orders` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '訂單id', `buyer_id` bigint(20) DEFAULT NULL COMMENT '使用者ID', `sku_type` char(32) DEFAULT NULL COMMENT '商品類型', `sku_quantity` int DEFAULT NULL COMMENT '商品數量', `gmt_create` datetime DEFAULT NULL COMMENT '建立時間', PRIMARY KEY (`id`) ) COMMENT='訂單表'; //結果表 CREATE TABLE `ads_gross` ( `prod_code` char(32) COMMENT '商品編號', `sale_num` int DEFAULT NULL COMMENT '銷售數量', primary key (prod_code) ) COMMENT='品類銷售總數結果表';