全部產品
Search
文件中心

AnalyticDB:DolphinScheduler調度XIHE SQL

更新時間:Apr 29, 2025

DolphinScheduler是一個分布式易擴充的可視化DAG工作流程工作調度開源系統,能高效地執行和管理巨量資料處理流程。您可以使用DolphinScheduler調度AnalyticDB for MySQL的XIHE SQL任務,提高資料處理的效率。

前提條件

  • 已安裝DolphinScheduler。具體操作,請參見DolphinScheduler官方文檔

  • 已在DolphinScheduler安裝目錄中配置MySQL驅動程式,且MySQL驅動程式為8.0.0及以上版本。下載連結,請參見mysql-connector-java

  • 已將運行DolphinScheduler的伺服器IP地址添加至AnalyticDB for MySQL叢集的白名單中。具體操作,請參見白名單

操作步驟

  1. 建立資料來源。

    1. 訪問DolphinScheduler Web介面,在頂部導覽列單擊源中心

    2. 單擊建立源,選擇源類型為MYSQL

    3. 在彈出的建立資料來源對話方塊中配置如下參數:

      參數

      說明

      資料來源

      選擇為MYSQL

      源名稱

      資料來源名稱。

      IP主機名稱

      AnalyticDB for MySQL叢集的串連地址。可通過控制台叢集資訊頁面,查看串連資訊。

      連接埠

      AnalyticDB for MySQL叢集的連接埠號碼,固定為3306。

      使用者名稱

      AnalyticDB for MySQL叢集的資料庫帳號。

      資料庫名

      AnalyticDB for MySQL叢集的資料庫名稱。

      說明

      其他參數為選填參數,詳情請參見MySQL資料來源

    4. 單擊測試連接,測試成功後,單擊確定

  2. 建立專案。

    1. 在頂部導覽列單擊專案管理

    2. 單擊建立專案

    3. 在彈出的建立專案對話方塊中配置專案名稱所屬使用者等參數。詳情請參見建立專案

  3. 建立工作流程。

    1. 單擊已建立的專案名稱,進入工作流程定義頁面。

    2. 單擊建立工作流程進入工作流程DAG編輯頁面

    3. 在頁面左側選擇SQL,並將其拖拽到右側空白畫布中。

    4. 在彈出的當前節點設定對話方塊中配置如下參數:

      參數

      說明

      資料來源類型

      選擇為MYSQL

      資料來源執行個體

      選擇步驟1建立的資料來源。

      SQL類型

      SQL作業的類型,例如查詢非查詢

      SQL語句

      業務具體的SQL語句。

    5. 單擊確認

    6. 單擊頁面右上方儲存,在彈出的基本資料對話方塊中配置工作流程名稱等參數。

    7. 單擊確定

  4. 運行工作流程。

    1. 單擊工作流程操作列的image按鈕,上線工作流程。

    2. 單擊工作流程操作列的image按鈕。

    3. 在彈出的啟動前請先設定參數對話方塊中,配置對應參數。

    4. 單擊確定,運行工作流程。

  5. 查看工作流程詳細資料。

    1. 在左側導覽列單擊任務執行個體

    2. 操作列,單擊image按鈕,查看工作流程執行結果和日誌資訊。