Distributed Execution Manager (DEM) 可執行自訂模型的業務邏輯,可與資料庫互動並可根據需要與外部資料庫和系統互動。

每個 DEM 執行個體都以 Worker 角色或 Orchestrator 角色運作。Worker 角色負責執行工作流程。Orchestrator 角色負責監控 DEM Worker 執行個體,處理要執行的工作流程,以及排程工作流程。

DEM Orchestrator 執行下列特定工作。

  • 監控 DEM Worker 的狀態,確保 Worker 執行個體在停止或中斷與 Model Manager 的連線時,其工作流程會放回佇列供其他 DEM Worker 選取。

  • 透過在排定的時間建立新工作流程執行個體來管理排定的工作流程。

  • 確保在指定時間僅一個特定排定的工作流程執行個體在執行中。

  • 在工作流程執行之前先進行處理,包括檢查工作流程的先決條件 (用於 RunOneOnly 功能實作),以及建立工作流程執行歷程記錄。

一個 DEM Orchestrator 執行個體被指定為執行這些工作的作用中 Orchestrator。因為 DEM Orchestrator 對執行工作流程至關重要,所以請在不同的機器上安裝至少一個額外的 Orchestrator 執行個體,以提供冗餘。Orchestrator 會自動安裝在同時執行 Manager Service 的機器上。額外的 DEM Orchestrator 用於監控作用中 Orchestrator 的狀態,以便在作用中 Orchestrator 離線時進行接管。