全部產品
Search
文件中心

Dataphin:步驟一:準備工作

更新時間:Mar 15, 2025

進行即時研發前您需完成相關雲資源的準備。雲資源準備包括Ververica Flink計算源、Quick BI開通(非必選)與配置以及資料來源的準備。本文將指導您完成本教程的雲資源準備工作。

步驟一:Realtime ComputeFlink版、Quick BI開通與配置

主流程

描述

操作指導

開通Realtime ComputeFlink版

購買Realtime ComputeFlink版。

開通Realtime ComputeFlink版

開通Quick BI(非必選)

購買Quick BI。

重要

非必選,也可以使用其他BI工具進行後續的可視化分析。

Quick BI購買、升級、續約、欠費

建立Flink專案空間

建立Flink專案空間,專案名稱為flink_dataphin

重要

阿里雲Realtime ComputeFlink版使用全域的專案空間,已建立的專案空間不支援再建立。建議使用flink_dataphin_001等方式建立。

管理專案空間

步驟二:準備資料來源

  1. 通過RDS建立MySQL8.0執行個體,擷取RDS執行個體ID,並在RDS控制台添加白名單,詳情請參見建立RDS MySQL執行個體。本教程中RDS資料來源名稱以flink_dataphin為例。

  2. 登入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='品類銷售總數結果表';