AnalyticDB for MySQL 2.0輸出組件用於向AnalyticDB for MySQL 2.0資料來源寫入資料。同步其他資料來源的資料至AnalyticDB for MySQL 2.0資料來源的情境中,完成來源資料源的資訊配置後,需要配置AnalyticDB for MySQL 2.0輸出組件的目標資料來源。本文為您介紹如何配置AnalyticDB for MySQL 2.0輸出組件。
操作步驟
在Dataphin首頁頂部功能表列,選擇研發 > Data Integration。
在整合頁面頂部功能表列選擇專案(Dev-Prod模式需要選擇環境)。
在左側導覽列中單擊離線整合,在離線整合列表中單擊需要開發的離線管道,開啟該離線管道的配置頁面。
單擊頁面右上方的組件庫,開啟組件庫面板。
在組件庫面板左側導覽列中需選擇輸出,在右側的輸出組件列表中找到AnalyticDB for MySQL 2.0組件,並拖動該組件至畫布。
單擊並拖動目標輸入、轉換或流程組件的
表徵圖,將其串連至當前AnalyticDB for MySQL 2.0輸出組件上。單擊AnalyticDB for MySQL 2.0輸出組件卡片中的
表徵圖,開啟AnalyticDB for MySQL 2.0輸出配置對話方塊。
在AnalyticDB for MySQL 2.0輸出配置對話方塊,配置參數。
參數
描述
基本設定
步驟名稱
即AnalyticDB for MySQL 2.0輸出組件的名稱。Dataphin自動產生步驟名稱,您也可以根據業務情境修改。命名規則如下:
只能包含中文、字母、底線(_)、數字。
不能超過64個字元。
資料來源
在資料來源下拉式清單中,展示所有AnalyticDB for MySQL 2.0類型的資料來源,包括您已擁有同步寫入權限的資料來源和沒有同步寫入權限的資料來源。單擊
表徵圖,可複製當前資料來源名稱。對於沒有同步寫入權限的資料來源,您可以單擊資料來源後的申請,申請資料來源的同步寫入權限。具體操作,請參見申請、續期和交還資料來源許可權。
如果您還沒有AnalyticDB for MySQL 2.0類型的資料來源,單擊建立資料來源,建立資料來源。具體操作,請參見建立AnalyticDB for MySQL 2.0資料來源
時區
將根據當前時區對時間格式資料進行處理,預設為所選資料來源中配置的時區,不支援修改。
說明對於V5.1.2版本之前建立的任務,可選擇資料來源預設配置或通道配置時區,預設選擇為通道配置時區。
資料來源預設配置:所選資料來源預設的時區。
通道配置時區:當前整合任務在屬性 > 通道配置中配置的時區。
表
選擇輸出資料的目標表。 可輸入表名關鍵字進行搜尋,或輸入準確表名後單擊精準尋找。選擇表後,系統將自動進行表狀態檢測。單擊
表徵圖,可複製當前所選表的表名稱。模式
選擇資料輸出的模式。模式包括:
Insert模式:Insert模式支援較小資料量(<1千萬條)的寫入。需配置準備語句和完成語句。
準備語句:匯入前執行的SQL指令碼。
完成語句:匯入後執行的SQL指令碼。
Load模式:Load模式支援大批量資料(>1千萬條)的寫入。需配置載入策略、Load參數、雲賬戶。
載入策略:選擇資料寫入目標表的策略。
覆蓋資料即以當前來源表為準,覆蓋目標表中的歷史資料。
追加資料即在目標表的已有的資料基礎上追加資料,且不修改歷史資料。
Load參數:用於MaxCompute中轉的串連,以JSON格式填寫,例如:
{"accessid":"XXX","accessKey":"XXX","odpsServer":"XXX","tunnelServer":"XXX","accountType":"aliyun","project":"transfer_project"}雲帳號:在Load模式下必填,雲帳號用於授權Load資料,填寫內容如:ALIYUN$****_data@aliyun.com。
批量寫入資料量(非必填)
一次性寫入的資料量大小,可同時設定批量寫入條數,寫入時系統將按兩個配置中先達到上限的量進行寫入,預設32M。
欄位對應
輸入欄位
根據上遊的輸入,為您展示輸入欄位。
輸出欄位
為您展示輸出欄位。支援進行以下操作:
欄位管理:單擊欄位管理選擇輸出欄位。

單擊
表徵圖,將已選的輸入欄位移入未選的輸入欄位。單擊
表徵圖,將未選的輸入欄位移入已選的輸入欄位。
大量新增:單擊大量新增,支援JSON、TEXT格式、DDL格式大量設定。
以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)、半形分號(;)、半形句號(.)。
資料行分隔符號用於分隔欄位名與欄位類型,預設為半形逗號(,)。
以DDL格式大量設定,例如:
CREATE TABLE tablename ( id INT PRIMARY KEY, name VARCHAR(50), age INT );
建立輸出欄位:單擊+建立輸出欄位,根據頁面提示填寫欄位並選擇類型。當前行完成配置後,單擊
表徵圖儲存。
映射關係
根據上遊的輸入和目標表的欄位,可以手動選擇欄位對應。映射關係包括同行映射和同名映射。
同名映射:對欄位名稱相同的欄位進行映射。
同行映射:源表和目標表的欄位名稱不一致,但欄位對應行的資料需要映射。只映射同行的欄位。
單擊確認,完成AnalyticDB for MySQL 2.0輸出組件的屬性配置。