(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210549329.8 (22)申请日 2022.05.20 (71)申请人 北京车网科技发展 有限公司 地址 102600 北京市大兴区北京经济技 术 开发区永晖大厦A座3层 (72)发明人 孙宁　宋娟　董航瑞　孟维宇　 何赛　贾宁　 (74)专利代理 机构 北京慧诚智道知识产权代理 事务所 (特殊普通合伙) 11539 专利代理师 戴燕 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) (54)发明名称 一种任务调度系统 (57)摘要 本发明实施例涉及一种任务调度系统， 所述 系统包括： 基础设施集群、 资源管理器、 决策引 擎、 云端控制器、 工作流引擎、 实时任务客户端、 实时任务处理引擎、 离线任务客户端和离线任务 处理引擎； 资源 管理器用于进行资源监控并将监 控信息向云端控制器同步； 决策引擎用于进行任 务规划并将规划结果向云端控制器发送； 云端控 制器用于对工作流引擎进行工作流任务推送； 工 作流引擎用于对工作流任务进行创建、 编辑、 查 询、 以及分解、 分发和状态更新处理； 实时任务处 理引擎用于在指定的基础设施上进行实时任务 计算； 离线任务处理引擎用于在离线任务启动时 段在指定的基础设施上进行离线任务计算。 通过 本发明系统能保证实时性要求较强的计算任务 得到及时执 行。 权利要求书5页 说明书16页 附图1页 CN 114816716 A 2022.07.29 CN 114816716 A 1.一种任务调度系统， 其特征在于， 所述系统包括： 基础 设施集群、 资源管理器、 决策引 擎、 云端控制器、 工作流引擎、 实时任务客户端、 实时任务处理引擎、 离线任务客户端和离线 任务处理引擎； 所述基础设施集群包括多个 基础设施； 所述资源管理器分别与所述基础设施集群、 所述云端控制器、 所述实时任务处理引擎 和所述离线任务处理引擎连接； 所述资源管理器用于对所述基础设施集群中各个所述基础 设施的资源使用状况进行资源监控处理得到对应的实时监控数据集合； 所述资源管理器还 用于根据所述实时监控数据集合向所述云端控制器进 行数据共享处理； 所述资源管理器还 用于对所述实时任务处 理引擎或所述离线任务处 理引擎进行基础设施分配处 理； 所述决策引擎与所述云端控制器连接； 所述决策引擎用于根据输入的车路协同数据进 行任务规划处理得到对应的规划任务数据集合， 并将携带了所述规划任务数据集合的决策 任务推送指令 向所述云端控制器发送； 所述规划任务数据集合包括规划任务名称、 规划任 务类型、 任务资源配置清单和任务输入数据， 所述规划任务类型包括实时任务类型和离线 任务类型； 所述云端控制器与 所述工作流引擎连接； 所述云端控制器用于根据所述规划任务数据 集合和所述实时监控数据集合进行工作流任务数据转换处理生成对应的工作流任务数据 包， 并根据所述工作流任务数据包 对所述工作流引擎进行工作流任务推送处 理； 所述工作流引擎分别与所述实时任务客户端和所述离线任务客户端连接； 所述工作流 引擎用于根据接收的所述工作流任务数据包进 行工作流任务创建处理； 所述工作流引擎还 用于对工作流任务进行编辑与查询处理； 所述工作流引擎还用于对工作流任务进行分解、 分发和状态更新处 理； 所述实时任务客户端与所述实时任务处理引擎连接； 所述实时任务客户端用于将所述 工作流引擎 发送的当前子任务数据包向所述 实时任务处理引擎转 发， 并将所述实时任务处 理引擎回发的子任务执 行结果数据向所述工作流引擎 转发； 所述实时任务处理引擎分别与所述资源管理器和所述基础 设施集群连接； 所述实时任 务处理引擎用于根据所述当前子任务数据包向所述资源管理器进行设施分配申请处理得 到所述基础设施集群中对应的分配设施资源， 并借助所述分配设施资源根据所述当前子任 务数据包进行实时任务计算处理得到对应的子任务执行结果数据， 并将所述子任务执行结 果数据向所述实时任务 客户端回发； 所述离线任务客户端与所述离线任务处理引擎连接； 所述离线任务客户端用于将所述 工作流引擎 发送的当前子任务数据包向所述离线任务处理引擎转 发， 并将所述离线任务处 理引擎回发的子任务执 行结果数据向所述工作流引擎 转发； 所述离线任务处理引擎分别与所述资源管理器和所述基础 设施集群连接； 所述离线任 务处理引擎用于根据所述当前子任务数据包进行离线任务启动时间查询处理得到对应的 离线任务启动时段， 并根据所述离线任务启动时段和所述当前子任务数据包向所述资源管 理器进行设施分配申请处理得到所述基础设施集群中对应的分配设施资源， 并借助所述分 配设施资源根据所述当前子任务数据包进行离线任务计算处理得到对应的所述子任务执 行结果数据， 并将所述子任务执 行结果数据向所述离线任务 客户端回发。 2.根据权利要求1所述的任务调度系统， 其特 征在于，权　利　要　求　书 1/5 页 2 CN 114816716 A 2所述基础设施至少包括交换机、 计算机、 服 务器、 数据库； 所述基础设施的资源至少包括CPU资源、 内存资源、 硬盘资源、 网络流量资源、 计算接口 资源。 3.根据权利要求1所述的任务调度系统， 其特 征在于， 所述资源管理器包括资源监控模块和资源分配模块； 所述资源监控模块分别与所述云 端控制器和所述资源分配模块连接； 所述资源分配模块分别与所述 实时任务处理引擎或所 述离线任务处 理引擎连接； 所述资源管理器具体用于在所述对所述基础设施集群中各个所述基础设施的资源使 用状况进 行资源监控处理 时， 由所述资源监控模块预先创建一个基础设施资源集合对所述 基础设施集群中各个所述基础设施的各类型资源的使用状况进行存储， 并每隔一个指 定时 间间隔就对所述基础设施资源集合进行一次内容复制从而得到对应的所述实时监控数据 集合； 其中， 所述基础设施资源集合包括多个基础设施数组， 所述基础设施数 组包括基础设 施标识和多个设施资源数组； 所述设施资源数组包括资源类型， 所述资源类型包括CPU类 型、 内存类型、 硬盘类型、 网络流量类型和 计算接口类型； 所述资源类型为CPU类型、 内存类 型、 硬盘类型或网络流量类型时所述设施资源数组还包括资源总量、 资源已 占用量和资源 剩余可分配量， 所述资源类型为计算接口类型时所述设施资源数组还 包括计算接口列表； 所述资源管理器具体用于在所述根据所述实时监控数据集合向所述云端控制器进行 数据共享处理时， 由所述资源监控模块在每产生一次所述实时监控数据集合时就将携带了 所述实时监控数据集 合的数据共享指令向所述云端控制器发送； 所述资源管理器具体用于在所述对所述实时任务处理引擎或所述离线任务处理引擎 进行基础设施分配处理时， 由所述资源分配模块接收所述实时任务处理引擎或所述离线任 务处理引擎 发送的基础设施申请指 令， 并从所述基础设施申请指 令中提取出当前资源配置 清单， 并将所述基础设施资源集合中各类资源的剩余可分配量都满足所述当前资源配置清 单要求的所述基础设施数组标记为匹配设施数组， 并从得到的所有所述匹配设施数组中任 选一个作为当次分配设施数组， 并根据所述当前资源配置清单对所述当次分配设施数组进 行资源已占用量和资源剩余可分配量调整， 并将所述当次分配设施数组对应的所述基础设 施作为与所述实时任务处理引擎或所述离线任务处理引擎当次基础设施申请指令对应的 所述分配设施资源。 4.根据权利要求1所述的任务调度系统， 其特 征在于， 所述决策引擎具体用于在所述根据输入的车路协同数据进行任务规划处理时， 从所述 车路协同数据中提取出数据标签与数据体； 并将所述数据体作为对应的所述任务输入数 据； 并将本地预设的车路协同数据任务对应表中数据标签字段与所述数据标签匹配的对应 记录作为匹配对应记录， 并将所述匹配对应记录的任务名称字段、 任务类型字段和任务配 置清单字段分别提取出来作为对应的所述规划任务名称、 所述规划任务类型和所述任务资 源配置清单； 并由得到的所述规划任务名称、 所述规划任务类型、 所述任务资源配置清单和 所述任务输入数据 组成对应的所述规划任务数据集合； 其中， 所述车路协同数据任务对应 表包括多个所述对应记录； 所述对应记录包括所述数据标签字段、 所述任务名称字段、 所述 任务类型字段和所述任务配置清单字段。 5.根据权利要求1所述的任务调度系统， 其特 征在于，权　利　要　求　书 2/5 页 3 CN 114816716 A 3