(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210526284.2 (22)申请日 2022.05.16 (71)申请人 江苏安超云软件 有限公司 地址 214000 江苏省无锡市经济开发区金 融三街6号1601室 (72)发明人 不公告发明人 　 (74)专利代理 机构 苏州友佳知识产权代理事务 所(普通合伙) 32351 专利代理师 储振 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/48(2006.01) (54)发明名称 基于分布式系统的任务调度方法及系统 (57)摘要 本发明提供了一种基于分布式系统的任务 调度方法及系统， 任务调度方法包括： 向分布式 系统中既有的主节点和/或从节 点中部署采集所 属工作节 点的资源属性信息的标签句柄； 通过标 签句柄采集待加入分布式系统的工作节点的节 点属性信息， 并向待加入分布式系统的工作节点 添加标签信息； 分布式系统接收任务， 获取任务 被分配到的工作节点对任务的资源消耗记录及 标签信息， 以在分布式系统接收新任务时， 采集 各工作节点基于执行任务的资源消耗记录及标 签信息， 以确定响应新任务的工作节点。 通过本 申请， 实现了对不同任务匹配工作节 点过程中的 合理性， 从而使得分布式系统在部署及运行过程 中不需要考虑工作节点的机 器性能差异。 权利要求书2页 说明书10页 附图4页 CN 114840343 A 2022.08.02 CN 114840343 A 1.基于分布式系统的任务调度方法， 其特 征在于， 包括： 向分布式系统中 既有的主节点和/或从节点中部署采集所属工作节点的资源属性信 息 的标签句柄； 通过所述标签句柄采集待加入所述分布式系统 的工作节点的节点属性信 息， 并向所述 待加入所述分布式系统的工作节点添加标签信息； 所述分布式系统接收任务， 获取所述任务被分配到的工作节点对所述任务的资源消耗 记录及所述标签信息， 以在分布式系统接 收新任务时， 采集各工作节点基于执行任务的资 源消耗记录及标签信息， 以确定响应所述 新任务的工作节点。 2.根据权利要求1所述的任务调度方法， 其特征在于， 所述标签句柄采集待加入所述分 布式系统的工作节点的节点属 性信息后， 通过标签句柄预设的标签规则生成标签信息， 或 者， 对已经保存的标签信息予以修改后保存。 3.根据权利要求1所述的任务调度方法， 其特征在于， 所述分布式系统接收任务或者新 任务后还 包括： 根据任务或者新任务的函数签名和/或哈希值执行取样操作取得任务取样信息， 并保 存任务取样信息与当前 标签信息的对应关系。 4.根据权利要求3所述的任务调度方法， 其特征在于， 当分布式系统接收后 续的新任务 时， 查询所述任务取样信息与当前标签信息的对应关系， 以确定响应相似任务所匹配的工 作节点。 5.根据权利要求3所述的任务调度方法， 其特征在于， 所述任务调度方法还包括： 在确 定主节点与从节点后， 对主节点与从节点执行节 点信息同步， 并保存同步后的节点信息， 所 述节点信息为加入所述分布式系统的工作节点响应新任务的前一次任务后所形成的资源 消耗记录 。 6.根据权利要求3所述的任务调度方法， 其特征在于， 所述任务调度方法还包括： 通过 返回值记录所述加入所述分布式系统的工作 节点响应新任务后所形成的资源消耗记录， 然 后将返回值写入标签句柄中的标签信息或者修改标签句柄中的标签信息以形成当前标签 信息， 并将所述当前 标签信息对所述加入所述分布式系统的工作节点执 行标记操作； 当分布式系统接收新任务 时调用所述当前标签信 息， 以确定响应所述新任务的工作节 点的调度策略， 其中， 所述响应所述新任务的工作节点为待加入所述分布式系统的工作节 点或者分布式系统在接收新任务时既有的工作节点。 7.根据权利要求3所述的任务调度方法， 其特征在于， 所述任务调度方法还包括： 主节 点将所述当前标签信息同步至从节点， 并由所述主节点侦测工作节点的性能指标， 以根据 所述性能指标确定 工作节点的优先级； 其中， 性能指标由响应CPU密集型任务、 响应内存密集型任务或者响应IO密集型任务中 的一种或者任意几种密集型任务的性能数据单独或者共同定义。 8.基于分布式系统的任务调度系统， 其特 征在于， 包括： 标签句柄与调度器， 所述标签句柄部署节点属性信息采集单 元及任务信息取样单 元； 所述标签句柄部署于分布式系统中既有的主节点和/或从节点中， 以通过所述节点属 性信息采集单元采集所属工作节点的资源属 性信息以及集待加入所述分布式系统的工作 节点的节点属性信息， 并向所述待加入所述分布式系统的工作节点添加标签信息；权　利　要　求　书 1/2 页 2 CN 114840343 A 2所述分布式系统接收任务， 由所述节点属性信 息采集单元获取所述任务被分配到的工 作节点对所述任务的资源消 耗记录及所述标签信息， 以在分布式系统接 收新任务时， 由所 述任务信息取样单元采集各工作 节点基于执行任务的资源消耗记录及标签信息， 以由调 度 器根据资源消耗记录及标签信息确定响应所述 新任务的工作节点。 9.根据权利要求8所述的任务调度系统， 其特 征在于， 还 包括： 节点信息存 储单元； 所述标签句柄采集待加入所述分布式系统的工作节点的节点属性信 息后， 通过节点属 性信息采集单元预设的标签规则生成标签信息， 并保存所述标签信息至所述节点信息存储 单元， 或者， 对节点信息存 储单元已经保存的标签信息予以修改后保存。 10.根据权利要求8所述的任务调度系统， 其特 征在于， 还 包括： 任务信息存 储单元； 所述分布式系统接收任务或者 新任务后还 包括： 通过所述任务信 息取样单元根据任务或者新任务的函数签名和/或哈希值执行取样操 作取得任务取样信息， 并保存任务取样信息与当前标签信息的对应关系至所述任务信息存 储单元。 11.根据权利要求8所述的任务调度系统， 其特征在于， 当分布式系统接收后续的新任 务时， 通过所述任务信息取样单元自所述任务信息存储单元查询所述任务取样信息与当前 标签信息的对应关系， 以确定响应相似 任务所匹配的工作节点。 12.根据权利要求10所述的任务调度系统， 其特征在于， 所述节点属性信 息采集单元确 定主节点与从节点， 并在确定主节点与从节点后， 对主节点与从节点执行节点信息同步， 并 将同步后的节点信息保存至任务信息存储单元， 所述节点信息为加入所述分布式系统的工 作节点响应新任务的前一次任务后所 形成的资源消耗记录 。 13.根据权利要求10所述的任务调度系统， 其特征在于， 所述任务信 息取样单元通过返 回值记录所述加入所述分布式系统的工作节点响应新任务后所形成的资源消耗记录， 然后 将返回值写入或者修改标签句柄中的标签信息以形成当前标签信息， 并将所述当前标签信 息对所述加入所述分布式系统的工作节点执 行标记操作， 并保存至任务信息取样单 元； 当分布式系统接收新任务时由调度器自所述任务信息取样单元调用所述当前标签信 息， 以确定响应所述新任务的工作 节点的调度策略， 其中， 所述响应所述新任务的工作 节点 为待加入所述分布式系统的工作节点或者分布式系统在接收新任务时既有的工作节点。 14.根据权利要求10所述的任务调度系统， 其特征在于， 主节点中的节点属性信 息采集 单元将所述当前标签信息同步至从节点， 并由所述主节点侦测工作节点的性能指标， 以根 据所述性能指标确定 工作节点的优先级； 其中， 性能指标由响应CPU密集型任务、 响应内存密集型任务或者响应IO密集型任务中 的一种或者任意几种密集型任务的性能数据单独或者共同定义。权　利　要　求　书 2/2 页 3 CN 114840343 A 3