進行實時研發前您需完成相關云資源的準備。云資源準備包括阿里云賬號資源準備、Dataphin開通與AccessKey配置、Ververica Flink計算源、Quick BI開通(非必選)與配置以及數據源的準備。本文將指導您完成本教程的云資源準備工作。
步驟一:阿里云賬號資源準備
主流程 | 描述 | 操作指導 |
準備阿里云賬號 | 創建阿里云賬號。 | |
創建RAM用戶 | 創建主賬號的RAM用戶。 |
步驟二:Dataphin開通與AccessKey配置
主流程 | 描述 | 操作指導 |
開通Dataphin | 購買Dataphin。 | |
配置AccessKey | 授權主賬號的AccessKey至Dataphin。 |
步驟三:實時計算Flink版、Quick BI開通與配置
主流程 | 描述 | 操作指導 |
開通實時計算Flink版 | 購買實時計算Flink版。 | |
開通Quick BI(非必選) | 購買Quick BI。 重要 非必選,也可以使用其他BI工具進行后續的可視化分析。 | |
創建Flink項目空間 | 創建Flink項目空間,項目名稱為flink_dataphin。 重要 阿里云實時計算Flink版使用全局的項目空間,已創建的項目空間不支持再創建。建議使用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='品類銷售總數結果表';
文檔內容是否對您有幫助?