HBase輸出組件用於向HBase資料來源寫入資料。同步其他資料來源的資料至HBase資料來源的情境中,完成來源資料的資訊配置後,需要配置HBase輸出組件的目標資料來源。本文為您介紹如何配置HBase輸出組件。
前提條件
已購買及開通了資料服務或標籤服務模組的高可用功能才可以進行資料來源的主備鏈路配置。
已建立HBase資料來源。具體操作,請參見建立HBase資料來源。
進行HBase輸出組件屬性配置的帳號,需具備該資料來源的同步寫入權限。如果沒有許可權,則需要申請資料來源許可權。具體操作,請參見申請、續期和交還資料來源許可權。
操作步驟
在Dataphin首頁頂部功能表列,選擇研發 > Data Integration。
在整合頁面頂部功能表列選擇專案(Dev-Prod模式需要選擇環境)。
在左側導覽列中單擊離線整合,在離線整合列表中單擊需要開發的離線管道,開啟該離線管道的配置頁面。
單擊頁面右上方的組件庫,開啟組件庫面板。
在組件庫面板左側導覽列中需選擇輸出,在右側的輸出組件列表中找到HBase組件,並拖動該組件至畫布。
單擊並拖動目標輸入、轉換或流程組件的
表徵圖,將其串連至當前HBase輸出組件上。單擊HBase輸出組件卡片中的
表徵圖,開啟HBase輸出配置對話方塊。
在HBase輸出配置對話方塊,配置參數。
參數
說明
基本設定
步驟名稱
即HBase輸出組件的名稱。Dataphin自動產生步驟名稱,您也可以根據業務情境修改。命名規則如下:
只能包含中文、字母、底線(_)、數字。
不能超過64個字元。
資料來源
在資料來源下拉式清單中,展示所有HBase類型的資料來源,包括您已擁有同步寫入權限的資料來源和沒有同步寫入權限的資料來源。單擊
表徵圖,可複製當前資料來源名稱。對於沒有同步寫入權限的資料來源,您可以單擊資料來源後的申請,申請資料來源的同步寫入權限。具體操作,請參見申請、續期和交還資料來源許可權。
如果您還沒有HBase類型的資料來源,單擊建立資料來源,建立資料來源。具體操作,請參見建立HBase資料來源。
選擇鏈路
已開通標籤服務高可用功能且選擇的Hbase資料來源主備鏈路為主備雙鏈路時,支援選擇主鏈路或備鏈路用於整合,僅影響生產資料來源。
表
選擇資料同步的目標表。
檔案編碼
選擇檔案編碼。檔案編碼包括UTF-8和GBK。
Rowkey
單擊添加,可以配置多個Hbase資料來源的Rowkey。預設支援常量的String、Int、Boolean、Long、Float、Short資料類型作為Hbase資料來源的Rowkey。
值的版本號碼來源
支援目前時間,固定時間或指定時間列。
目前時間:即使用目前時間作為值的版本號碼來源。
指定時間:固定時間需要配置選擇時間參數,選擇值的版本號碼來源時間。
指定時間列:指定時間列需要配置選擇時間列參數,選擇表中可以作為值的版本號碼來源的時間列。
欄位對應
輸入欄位
根據上遊組件的輸出,為您展示輸入欄位。
輸出欄位
為您展示輸出欄位。 Dataphin支援通過大量新增和建立輸出欄位的方式配置輸出欄位:
大量新增:單擊大量新增,支援JSON、TEXT格式大量設定。
以JSON格式大量設定,例如:
// 樣本: [{"name": "user_id","type": "String"}, {"name": "user_name","type": "String"}]說明name表示引入的欄位名稱,type表示引入後的欄位類型。 例如:
"name":"user_id","type":"String"表示把欄位名為user_id的欄位引入,設定欄位類型為String。以TEXT格式大量設定,例如:
// 樣本: user_id,String user_name,String行分隔字元用於分隔每個欄位的資訊,預設為分行符號(\n),可支援分行符號(\n)、分號(;)、點(.)。
資料行分隔符號用於分隔欄位名與欄位類型,預設英文逗號(,)。
建立輸出欄位。
單擊+建立輸出欄位,根據頁面提示填寫欄位及選擇類型。
複製上遊欄位。
單擊複製上遊欄位,系統將根據上遊的欄位名自動產生輸出欄位。
管理輸出欄位。
同時您也可以對已添加的欄位執行如下操作:
單擊操作列下的
表徵圖,編輯已有的欄位。單擊操作列下的
表徵圖,刪除已有的欄位。
映射關係
映射關係用於將源表的輸入欄位和目標表的輸出欄位對應起來,便於後續進行資料同步。映射關係包括同名映射和同行映射。適用情境說明如下:
同名映射:對欄位名稱相同的欄位進行映射。
同行映射:源表和目標表的欄位名稱不一致,但欄位對應行的資料需要映射。只映射同行的欄位。
單擊確認,完成HBase輸出組件的屬性配置。