極速同步管道任務以Apache Arrow列式記憶體格式作為端到端的資料轉送載體,通過向量化批量讀寫、零拷貝映射及Arrow Flight SQL傳輸,提升大批量資料同步情境下的同步吞吐。本文為您介紹如何建立極速同步管道任務。
前提條件
已完成資料來源配置。您需要在建立極速同步管道任務前,配置好需要同步的來來源資料源與目標資料來源,以便在配置輸入、輸出組件時選擇資料來源。極速同步管道任務支援以下資料來源:
操作步驟
步驟一:建立極速同步管道
-
在Dataphin首頁的頂部功能表列中,選擇研發 > Data Integration。
-
在整合頁面頂部功能表列選擇專案(Dev-Prod模式需要選擇環境)。
-
單擊離線整合列表中的 建立 表徵圖,選擇極速同步,開啟建立極速同步管道對話方塊。
-
在建立極速同步管道對話方塊中,配置管道相關參數。
參數
描述
管道名稱
填寫管道名稱。支援最長64個字元,不支援特殊字元:豎線(|)、正斜線(/)、反斜線(\)、半形冒號(:)、半形問號(?)、角括弧(<>)、星號(*)、半形單引號('')。
調度類型
選擇管道的調度類型。調度類型包括:
-
周期性節點:指需定期執行的任務。
-
手動節點:指沒有依賴關係,需手動觸發的任務。
描述
填寫極速同步管道的簡單描述,1000個字元以內。
選擇目錄
選擇任務所存放的目錄。
若未建立目錄,您可以建立檔案夾,操作方法如下:
-
在頁面左側計算工作清單上方單擊建立檔案夾表徵圖,開啟建立檔案夾對話方塊。
-
在建立檔案夾對話方塊中輸入檔案夾名稱並根據需要選擇目錄位置。
-
單擊確定。
-
-
單擊 確定 ,完成極速同步管道建立。
步驟二:開發極速同步管道指令碼
極速同步管道任務的組件庫僅支援輸入組件與輸出組件,各組件的配置內容與離線管道任務的輸入、輸出組件一致,同時支援切換為指令碼模式。
極速同步管道任務的輸入、輸出組件按資料來源對Arrow的支援程度分為兩類:
-
Apache Arrow加速:資料來源提供原生列式讀寫通路,資料無需行列轉換即可以Arrow格式傳輸。
-
Apache Arrow適配:資料來源不提供原生列式通路,讀寫時需在行格式與Arrow列式格式之間轉換。
支援以下輸入組件:
|
輸入組件 |
Arrow能力 |
Arrow讀寫入模式 |
說明 |
|
Apache Arrow適配 |
JDBC轉Arrow列式 |
通過JDBC讀取,結果集批量轉換為Arrow列式記憶體格式後傳輸。 |
|
|
Apache Arrow適配 |
JDBC轉Arrow列式 |
通過JDBC讀取,結果集批量轉換為Arrow列式記憶體格式後傳輸。 |
|
|
Apache Arrow適配 |
JDBC轉Arrow列式 |
通過JDBC讀取,結果集批量轉換為Arrow列式記憶體格式後傳輸。 |
|
|
Apache Arrow適配 |
JDBC轉Arrow列式 |
通過JDBC讀取,結果集批量轉換為Arrow列式記憶體格式後傳輸。 |
|
|
Apache Arrow加速 |
Storage API(Arrow) |
通過MaxCompute Storage API以原生Arrow格式讀取,零轉換、高吞吐。 |
|
|
Apache Arrow加速 |
列式檔案零拷貝 |
ORC/Parquet/Text檔案直接映射Arrow記憶體布局,零拷貝讀取免還原序列化。 |
|
|
Apache Arrow加速 |
列式檔案零拷貝 |
ORC/Parquet/Text按列式布局零拷貝映射到Arrow,向量化掃描。 |
|
|
Apache Arrow加速 |
Arrow Flight SQL |
通過Doris FE的Arrow Flight SQL高速連接埠(預設8070)列式流式讀取。 |
|
|
Apache Arrow加速 |
Arrow Flight SQL |
通過SelectDB FE的Arrow Flight SQL高速連接埠(預設8070)列式流式讀取,需指定Warehouse(計算叢集)。 |
支援以下輸出組件:
|
輸出組件 |
Arrow能力 |
Arrow讀寫入模式 |
說明 |
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
|
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
|
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
|
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
|
|
Apache Arrow加速 |
Storage API(Arrow) |
通過MaxCompute Storage API以原生Arrow格式寫入,零轉換、高吞吐。 |
|
|
Apache Arrow加速 |
列式檔案零拷貝 |
按Arrow記憶體布局直接寫出ORC/Parquet/Text檔案,免序列化開銷。 |
|
|
Apache Arrow加速 |
列式檔案零拷貝 |
按Arrow記憶體布局直接寫出ORC/Parquet/Text檔案,免序列化開銷。 |
|
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
|
|
Apache Arrow適配 |
Arrow列式轉JDBC |
將Arrow列式資料轉換為行格式後通過JDBC寫入。 |
步驟三:管道調度配置
單擊開發畫布功能表列的調度配置按鈕,配置極速同步管道任務的基本資料、調度配置、調度依賴、調度參數、回合組態及資源配置。詳情請參見:
步驟四:儲存並提交 極速同步管道任務
-
單擊畫布上方的儲存表徵圖,儲存極速同步管道任務。
-
單擊畫布上方的提交表徵圖,在提交備忘對話方塊中填寫備忘資訊後,單擊確定並提交。
後續步驟
-
如果您的開發模式是Dev-Prod模式,則需要發布任務後才能參與生產環境的調度。
-
如果您的開發模式是Basic模式,則提交成功後的任務即可參與生產環境的調度,您可前往營運中心查看已提交的任務。