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 脱机时予以接管。