DataWorks：StarRocks

背景資訊

StarRocks是新一代極速全情境MPP（Massively Parallel Processing）資料庫，相容MySQL協議的OLAP分析引擎，提供了卓越的效能和豐富的OLAP情境模型，包括OLAP多維分析、資料湖分析、高並發查詢以及即時資料分析。

前提條件

• 已建立商務程序。

  資料開發（DataStudio）基於商務程序執行不同引擎的具體開發操作，因此，建立節點前需先建立商務程序，操作詳情請參見建立商務程序。

• 已建立StarRocks資料來源。

  您需先將您的StarRocks資料庫建立為DataWorks的StarRocks資料來源，詳情請參見建立StarRocks資料來源。

  說明

  StarRocks節點僅支援使用JDBC串連串方式建立的StarRocks資料來源。

• （可選，RAM帳號需要）進行任務開發的RAM帳號已被添加至對應工作空間中，並具有開發或空間管理員（許可權較大，謹慎添加）角色許可權。新增成員並授權，詳情請參見為工作空間增加空間成員。

使用限制

支援的地區：華東1（杭州）、華東2（上海）、華北2（北京）、華南1（深圳）、西南1（成都）、中國香港、新加坡、馬來西亞（吉隆坡）、德國（法蘭克福）、美國（矽谷）、美國（維吉尼亞）。

步驟一：建立StarRocks節點

1. 進入資料開發頁面。

   登入DataWorks控制台，切換至目標地區後，單擊左側導覽列的資料開發與治理 > 資料開發，在下拉框中選擇對應工作空間後單擊進入資料開發。

2. 按右鍵目標商務程序，選擇建立節點 > 資料庫 > StarRocks。

3. 在建立節點對話方塊輸入節點名稱，單擊確認，節點建立完成，您可在節點中進行對應任務的開發與配置。

步驟二：開發StarRocks任務

（可選）選擇StarRocks資料來源

如果您的工作空間建立了多個StarRocks資料來源，則需先在StarRocks節點編輯頁面選擇合適的資料來源。如果僅建立了一個StarRocks資料來源，則預設使用該資料來源進行開發操作。

開發SQL代碼：簡單樣本

在StarRocks節點的代碼編輯地區編寫要執行的StarRocks任務。樣本查詢StarRocks資料庫中所有基本表（BASE TABLE）的資訊，代碼如下：

SELECT * FROM information_schema.tables
WHERE table_type = 'BASE TABLE';

開發SQL代碼：使用調度參數

DataWorks提供的調度參數可實現周期調度情境下代碼動態入參，您可在節點任務中通過${變數名}的方式定義代碼中的變數，並在節點編輯頁面右側導覽列的調度配置>調度參數，為該變數賦值。調度參數支援的格式及配置詳情，請參見調度參數支援的格式、配置並使用調度參數。

樣本如下代碼中的調度參數a取值為$[yyyymmdd]（表示今天），則該代碼為查詢當天資料庫中建立的表資訊。

SELECT * FROM information_schema.tables
WHERE CREAT_TIME = '${a}';

步驟三：配置任務調度

如您需要周期性執行建立的節點任務，可單擊節點編輯頁面右側的調度配置，根據業務需求配置該節點任務的調度資訊。配置詳情請參見任務調度屬性配置概述。

步驟五：提交發布任務

節點任務配置完成後，需執行提交發佈動作，提交發布後節點即會根據調度配置內容進行周期性運行。

1. 單擊工具列中的表徵圖，儲存節點。

2. 單擊工具列中的表徵圖，提交節點任務。

   提交時需在提交對話方塊中輸入變更描述，並根據需要選擇是否在節點提交後執行程式碼檢閱。

   說明

   • 您需設定節點的重跑屬性和依賴的上遊節點，才可提交節點。

   • 程式碼檢閱可對任務的代碼品質進行把控，防止由於任務代碼有誤，未經審核直接發布上線後出現任務報錯。如進行程式碼檢閱，則提交的節點代碼必須通過評審人員的審核才可發布，詳情請參見程式碼檢閱。

如您使用的是標準模式的工作空間，任務提交成功後，需單擊節點編輯頁面右上方的發布，將該任務發布至生產環境執行，操作請參見發布任務。

後續步驟

任務提交發布後，會基於節點的配置周期性運行，您可單擊節點編輯介面右上方的營運，進入營運中心查看周期任務的調度運行情況。詳情請參見查看並管理周期任務。