本文介紹配置目標庫資訊的具體方法。
前提條件
-
當前僅支援在華東1(杭州)、華東2(上海)、華北1(青島)、華北2(北京)、華北3(張家口)、華南1(深圳)、華南3(廣州)和中國香港建立ETL任務。
-
當前目標庫支援MySQL、PolarDB MySQL、Oracle、AnalyticDB MySQL 3.0、PolarDB PostgreSQL、PostgreSQL、DB2 LUW、DB2 iSeries(AS/400)、AnalyticDB PostgreSQL、SQLServer、Mariadb、DRDS(PolarDB-X 1.0)、PolarDB Oracle、Tablestore。
-
已建立目標庫。
-
已完成資料來源資訊和轉換組件的配置。
-
由於ETL功能暫不支援結構遷移,所以您需要根據轉換條件在目標庫側完成對應表結構的建立。例如A表中包含欄位1、欄位2和欄位3,B表中包含欄位3、欄位4和欄位5,對A表和B表通過做JOIN操作後,需要輸出欄位1、欄位2、欄位3、欄位4和欄位5,則需要在目標庫側建立做JOIN操作後的C表,C表中包含欄位1、欄位2、欄位3、欄位4和欄位5。
操作步驟
下文以配置MySQL為例進行介紹。
-
進入ETL任務的列表頁面。
-
在左側導覽列,單擊ETL。
-
單擊左上方的
,在新增資料流對話方塊中,您需在資料流名稱配置ETL任務名稱,選擇開發方式為DAG。 -
單擊確認。
-
完成資料來源資訊的配置,配置方法請參見配置源庫資訊。
-
完成轉換組件的配置,配置方法請參見配置轉換組件。
-
在頁面左側,將輸出 MySQL節點拖拽至頁面右側畫布的空白地區。
-
將滑鼠指標移動至已完成配置的目標轉換組件,單擊圓點拉出連接線,串連目標轉換組件和輸出 MySQL-1。
-
單擊畫布地區的輸出 MySQL-1頁面,根據頁面資訊配置目標庫資訊。
-
設定以下參數,配置節點資訊。
參數
說明
請輸入資料來源名稱
DTS會自動產生一個資料來源名稱,建議配置具有業務意義的名稱(無唯一性要求),便於後續識別。
地區
選擇目標庫所在地區。
執行個體列表
選擇目標庫所在資料庫的執行個體名稱。您也可以單擊下方的建立執行個體進行建立,建立方法請參見執行個體管理。
表映射
選擇目標庫通過轉換處理後需要儲存的目標表。
在選擇目標表地區,單擊目標表。
-
根據實際需要,在欄位對應頁面的列名稱列,勾選需要的參數。
本樣本中,欄位對應表格包含以下源端欄位:orderid(int(11))、username(char(32))、ordertime(datetime)、commodity(varchar(32))、phonenumber(int(11))、address(text),各欄位自動對應到同名目標欄位。注意:Flink 中無 datetime 類型,如果源端表欄位類型是 datetime,會使用 timestamp 類型轉換,其取值需在 timestamp 範圍之內。
-
執行結果
完成配置的目標庫右側不顯示
時,說明配置完成。