天天看點

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

本頁目錄

注冊上下遊存儲操作步驟如下。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

登入DataHub

登入

DataHub控制台

建立DataHub源表

為簡化問題,我們将源源不斷的資料抽象簡化為如下二維表。datahub_IpPlace

字段名 類型 注釋
name varchar 名字
place 位址
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

建立的schema示意圖如下。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

上傳DataHub測試資料

為了友善使用者測試作業我們提供

測試資料

,點選下載下傳後利用DataHub的檔案上傳工具即可完成資料采集。

上傳DATAHUB源表的資料。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

注冊RDS

如果還沒有RDS執行個體,請參閱

RDS購買流程
注意: 請選擇經典網絡進行測試。
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

建立資料庫賬号。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲
實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

登入資料庫。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

RDS維表建立

測試維表名稱:rds_dim

Place

建立的維表schema示意圖如下:

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

上傳dim表測試資料。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲
  1. INSERT INTO `rds_dim`(`name` ,`Place` )VALUES('test01','beijing')

說明:實際生産應用中,我們很少有機會利用檔案上傳工具進行資料采集工作。更多資料采集工具的使用請參 資料采集

RDS結果表建立

測試結果表名稱:rds_IpPlace

建立的結果表schema示意圖如下。

實時計算Flink > 快速入門 —— 步驟二:注冊上下遊存儲

本文轉自實時計算——

步驟二:注冊上下遊存儲