-
公开(公告)号:CN112783123B
公开(公告)日:2021-11-19
申请号:CN202011623798.7
申请日:2020-12-30
Applicant: 北京理工大学
IPC: G05B19/418
Abstract: 本发明涉及一种工作流调度执行单元控制方法和控制器。本发明通过采用快通路系统能够高速接收工作流,由内部的多生产者单消费者模型队列缓存,并由工作流调度执行单元分配器根据工作流调度执行单元预选表向工作流调度执行单元发送工作流。快通路系统不负责构建和维护预选表,且其能够实现工作流的高速路由。工作流路由到工作流调度执行单元的准确性由工作流调度执行单元预选表保障,工作流调度执行单元预选表由慢通路系统内各模块根据系统当前状态(工作流调度执行单元规模、容量和压力)构建并维护,进而能解决高并发、高流速工作流的接收问题和超大规模分布式工作流调度执行单元的管理和大规模工作流高速、精准路由问题。
-
公开(公告)号:CN113032126A
公开(公告)日:2021-06-25
申请号:CN202110372038.1
申请日:2021-04-07
Applicant: 北京理工大学
Abstract: 本发明涉及一种高并发云工作流调度引擎跨集群通信系统及方法。该系统的控制器模块采用Service和Deployment方式容器化部署到Kubernetes的Master主集群;生成器模块采用Shell脚本方式容器化部署于各个集群,每个集群以Service和Deployment方式部署唯一的生成器容器;控制器模块和生成器模块均以Service NodePort方式对外提供访问,且以gRPC方式跨越集群通信;分布式数据库在各个集群中单独部署,用于存储调度器模块的资源请求记录;缓存数据库采用分布式架构部署,用于存储全局的工作流信息记录。本发明可以提高系统的灵活性,实现高效通信。
-
公开(公告)号:CN112948088A
公开(公告)日:2021-06-11
申请号:CN202110283971.1
申请日:2021-03-17
Applicant: 北京理工大学
Abstract: 本发明公开一种云计算平台中的云工作流智能管理与调度系统,包括:系统前端、调度控制器、云工作流调度器和资源分配器;系统前端上传云工作流文件;调度控制器接收云工作流文件后生成启动云工作流调度器信息;资源分配器接收启动云工作流调度器信息后通过容器管理平台获取剩余资源;容器管理平台接收创建云工作流调度器请求信息后在节点上创建多个云工作流调度器;各云工作流调度器根据云工作流文件确定资源配置总需求,并接收剩余资源,根据资源配置总需求和剩余资源生成云工作流计算节点,处理云工作流文件。本发明公开的方案能布置在大规模分布式集群上,能把云工作流接收比例提高20%,在多负载环境下,高效、可靠完成工作流任务管理与调度。
-
公开(公告)号:CN112698931A
公开(公告)日:2021-04-23
申请号:CN202110033497.7
申请日:2021-01-12
Applicant: 北京理工大学
Abstract: 本发明涉及一种云工作流分布式调度系统。该系统包括:调度器控制器、分布式云工作流调度模块和云工作流状态数据库模块。通过采用调度器控制器能够快速将云工作流进行动态分配、调度;通过采用分布式云工作流调度模块能够弹性化调整调度数量从而适应不同规模的云工作流调度,以能够在提高云资源共享效率的同时,节约用户成本。云工作流状态数据库模块用于存储云工作流状态,从而保障云工作流执行过程中出现意外时系统能够对断点具有记忆性,从断点处重新执行云工作流。
-
公开(公告)号:CN112698931B
公开(公告)日:2022-11-11
申请号:CN202110033497.7
申请日:2021-01-12
Applicant: 北京理工大学
Abstract: 本发明涉及一种云工作流分布式调度系统。该系统包括:调度器控制器、分布式云工作流调度模块和云工作流状态数据库模块。通过采用调度器控制器能够快速将云工作流进行动态分配、调度;通过采用分布式云工作流调度模块能够弹性化调整调度数量从而适应不同规模的云工作流调度,以能够在提高云资源共享效率的同时,节约用户成本。云工作流状态数据库模块用于存储云工作流状态,从而保障云工作流执行过程中出现意外时系统能够对断点具有记忆性,从断点处重新执行云工作流。
-
公开(公告)号:CN112783123A
公开(公告)日:2021-05-11
申请号:CN202011623798.7
申请日:2020-12-30
Applicant: 北京理工大学
IPC: G05B19/418
Abstract: 本发明涉及一种工作流调度执行单元控制方法和控制器。本发明通过采用快通路系统能够高速接收工作流,由内部的多生产者单消费者模型队列缓存,并由工作流调度执行单元分配器根据工作流调度执行单元预选表向工作流调度执行单元发送工作流。快通路系统不负责构建和维护预选表,且其能够实现工作流的高速路由。工作流路由到工作流调度执行单元的准确性由工作流调度执行单元预选表保障,工作流调度执行单元预选表由慢通路系统内各模块根据系统当前状态(工作流调度执行单元规模、容量和压力)构建并维护,进而能解决高并发、高流速工作流的接收问题和超大规模分布式工作流调度执行单元的管理和大规模工作流高速、精准路由问题。
-
公开(公告)号:CN112948088B
公开(公告)日:2022-10-04
申请号:CN202110283971.1
申请日:2021-03-17
Applicant: 北京理工大学
Abstract: 本发明公开一种云计算平台中的云工作流智能管理与调度系统,包括:系统前端、调度控制器、云工作流调度器和资源分配器;系统前端上传云工作流文件;调度控制器接收云工作流文件后生成启动云工作流调度器信息;资源分配器接收启动云工作流调度器信息后通过容器管理平台获取剩余资源;容器管理平台接收创建云工作流调度器请求信息后在节点上创建多个云工作流调度器;各云工作流调度器根据云工作流文件确定资源配置总需求,并接收剩余资源,根据资源配置总需求和剩余资源生成云工作流计算节点,处理云工作流文件。本发明公开的方案能布置在大规模分布式集群上,能把云工作流接收比例提高20%,在多负载环境下,高效、可靠完成工作流任务管理与调度。
-
公开(公告)号:CN113032126B
公开(公告)日:2022-09-20
申请号:CN202110372038.1
申请日:2021-04-07
Applicant: 北京理工大学
Abstract: 本发明涉及一种高并发云工作流调度引擎跨集群通信系统及方法。该系统的控制器模块采用Service和Deployment方式容器化部署到Kubernetes的Master主集群;生成器模块采用Shell脚本方式容器化部署于各个集群,每个集群以Service和Deployment方式部署唯一的生成器容器;控制器模块和生成器模块均以Service NodePort方式对外提供访问,且以gRPC方式跨越集群通信;分布式数据库在各个集群中单独部署,用于存储调度器模块的资源请求记录;缓存数据库采用分布式架构部署,用于存储全局的工作流信息记录。本发明可以提高系统的灵活性,实现高效通信。
-
-
-
-
-
-
-