全部產品
Search
文件中心

Realtime Compute for Apache Flink:任務編排(公測)

更新時間:Sep 13, 2024

任務編排是一個全託管的工作流程調度服務,通過可視化的操作介面輕鬆地編排批作業啟動並執行順序,構建資料倉儲,在Realtime ComputeFlink版平台實現開發、調度、部署和營運一體化。

重要
  • 任務編排目前為公測功能,公測階段不保障服務等級協議SLA,詳情請參見Realtime ComputeFlink版服務等級協議(SLA)。如果您在使用過程中遇到相關問題,可以提交工單

  • 僅華東2(上海)、華東1(杭州)、華北2(北京)、華南1(深圳)、華北3(張家口)、新加坡地區支援任務編排功能。

功能介紹

任務編排.png

  • 可視化管理:支援通過可視化的方式建立或管理工作流程。

  • 調度類型:支援手動觸發和周期調度兩種調度類型。

  • 定時管理:支援使用Cron運算式設定複雜規則。

  • 資源隊列:支援工作流程和工作流程節點選擇不同的部署目標。

基本概念

  • 工作流程

    通過任務編排建立工作流程,並在工作流程中定義調度節點以及調度策略,從而安排任務在指定的時間運行。工作流程是一個Dag(有向非循環圖)。

  • 工作流程節點

    工作流程中一個具體執行任務的節點。工作流程節點需關聯到一個已經部署的作業。

  • 工作流程執行個體

    工作流程每運行一次會產生一條工作流程執行個體。

  • 工作流程節點執行個體

    工作流程執行個體中的每個節點對應的就是工作流程節點執行個體。

  • 依賴

    節點之間啟動並執行相互依賴。例如節點A—>節點B,即節點A是節點B的上遊依賴,節點B的運行依賴節點A,在滿足節點B啟動並執行其他條件外,還需要節點A完成運行,節點B才能運行。

  • 工作流程版本

    工作流程版本指工作流程每次編輯(例如添加或刪除節點、變更依賴關係等)儲存後會產生一個新的工作流程版本。

使用流程

相關文檔