DataWorks的AnalyticDB for MySQL節點可進行AnalyticDB for MySQL任務的開發和周期性調度,以及與其他作業的集成操作。本文為您介紹使用AnalyticDB for MySQL節點進行任務開發的主要流程。
前提條件
已購買AnalyticDB for MySQL,詳情請參見創建集群。
已創建業務流程。
數據開發(DataStudio)基于業務流程執行不同引擎的具體開發操作,因此,創建節點前需先創建業務流程,操作詳情請參見創建業務流程。
已創建AnalyticDB for MySQL數據源并綁定至數據開發(DataStudio)。
您需先將您的AnalyticDB for MySQL數據庫創建為DataWorks的AnalyticDB for MySQL數據源并綁定至數據開發(DataStudio),才可通過AnalyticDB for MySQL數據源訪問AnalyticDB for MySQL數據,進行后續的開發操作。詳情請參見創建AnalyticDB for MySQL3.0數據源、開發前準備:綁定數據源或集群。
背景信息
AnalyticDB for MySQL是阿里云的一種分析型數據庫,詳情請參見云原生數據倉庫MySQL版。
步驟一:創建AnalyticDB for MySQL節點
進入數據開發頁面。
登錄DataWorks控制臺,切換至目標地域后,單擊左側導航欄的 ,在下拉框中選擇對應工作空間后單擊進入數據開發。
右鍵單擊目標業務流程,選擇
。在新建節點對話框中輸入節點名稱,單擊確認,節點創建完成,您可在節點中進行對應任務的開發與配置。
步驟二:開發AnalyticDB for MySQL任務
(可選)選擇AnalyticDB for MySQL數據源
如果您的工作空間創建了多個AnalyticDB for MySQL數據源,則需先在AnalyticDB for MySQL節點編輯頁面選擇合適的數據源。如果僅創建了一個AnalyticDB for MySQL數據源,則默認使用該數據源進行開發操作。
開發SQL代碼
在AnalyticDB for MySQL節點的代碼編輯區域編寫要執行的AnalyticDB for MySQL任務。示例運行的任務代碼如下。
show tables;
步驟三:配置任務調度
如您需要周期性執行創建的節點任務,可單擊節點編輯頁面右側的調度配置,根據業務需求配置該節點任務的調度信息。配置詳情請參見任務調度屬性配置概述。
您需要設置節點的重跑屬性和依賴的上游節點,才可以提交節點。
步驟四:調試任務代碼
您可根據需要執行如下調試操作,查看任務是否符合預期。
步驟五:提交發布任務
節點任務配置完成后,需要執行提交發布操作,提交發布后節點即會根據調度配置內容進行周期性運行。
單擊工具欄中的圖標,保存任務。
單擊工具欄中的圖標,提交任務。
提交時需在提交對話框中輸入變更描述,并根據需要選擇是否在任務提交后執行代碼評審。
說明您需要設置節點的重跑屬性和依賴的上游節點,才可提交任務。
代碼評審可對任務的代碼質量進行把控,防止由于任務代碼有誤,未經審核直接發布上線后出現任務報錯。如進行代碼評審,則提交的任務代碼必須通過評審人員的審核才可發布,詳情請參見代碼評審。
如您使用的是標準模式的工作空間,任務提交成功后,需單擊節點編輯頁面右上方的發布,將該任務發布至生產環境執行,操作請參見發布任務。
后續步驟
任務提交發布后,會基于節點的配置周期性運行,您可單擊節點編輯界面右上角的運維,進入運維中心查看周期任務的調度運行情況。詳情請參見查看并管理周期任務。