(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210461614.4 (22)申请日 2022.04.28 (71)申请人 中国电力科 学研究院有限公司 地址 100192 北京市海淀区清河小营东路 15号 申请人 国家电网有限公司 　 国网福建省电力有限公司电力科 学 研究院 (72)发明人 肖凯　王晓辉　刘鹏　季知祥　 何金栋　赵志超　谢鹏　 (74)专利代理 机构 北京中巡通大知识产权代理 有限公司 1 1703 专利代理师 孟大帅 (51)Int.Cl. G06F 9/50(2006.01)G06Q 10/06(2012.01) G06F 9/48(2006.01) G06F 16/23(2019.01) G06Q 50/06(2012.01) (54)发明名称 用于电力行业定时任务调度的方法、 系统、 设备及介质 (57)摘要 本发明公开了一种用于电力行业定时任务 调度的方法、 系统、 设备及介质， 所述方法包括： 获取待调度的电力行业定时任务， 基于电力行业 定时任务的属性信息生成多个任务批次； 周期性 检查每个任务批次中每个定时任务的依赖状态 和超时状态， 获得依赖状态检查结果和超时状态 检查结果； 将依赖状态检查结果和超时状态检查 结果均符合预设要求的任务批次中的定时任务， 分别分配给预选取的分布式设置的工作机进行 执行， 实现分布式调度。 本发明提供的定时任务 分布式调度处理方法， 相比于目前的单点调度处 理， 具有较高的处 理效率。 权利要求书3页 说明书11页 附图3页 CN 114968557 A 2022.08.30 CN 114968557 A 1.一种用于电力行业定时任务调度的方法， 其特 征在于， 包括以下步骤： 获取待调度的电力行业定时任务， 基于电力行业定时任务的属性信 息生成多个任务批 次； 周期性检查每个任务批次中每个定时任务的依赖状态和超时状态， 获得依赖状态检查 结果和超时状态检查结果； 将依赖状态检查结果和超时状态检查结果均符合预设要求的任务批次中的定时任务， 分别分配给 预选取的分布式设置的工作机进行 执行， 实现分布式调度。 2.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述获 取待调度的电力行业定时任务的步骤 包括： 通过周期扫描预设任务表或外 部触发的方式， 获取待调度的电力行业定时任务。 3.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述电 力行业定时任务的属 性信息包括开始 时间、 结束时间、 执行频率和依赖信息中的一种或多 种。 4.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述依 赖状态检查包括路径 依赖检查、 第三方依赖检查和逻辑依赖检查中的一种或多种。 5.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述超 时状态检查包括依赖超时检查和产出超时检查中的一种或两种。 6.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述将 依赖状态检查结果和超时状态检查结果均符合预设要求的任务批次中的定时任务， 分别分 配给预选取的分布式设置的工作机进行 执行， 实现分布式调度的步骤具体包括： 采用策略1至策略5 中的一种或多种， 将依赖状态检查结果和超时状态检查结果均符合 预设要求的任务批次中的定时任务， 分别分配给 预选取的分布式设置的工作机； 分配定时任务的工作机基于数据库锁的方式， 上报取得触发器后执行分配的定时任 务； 其中， 策略1， 通过乘以固定值再求模最后取特定位数的方式， 分别获得每个定时任务 编号和工作机编号的哈希值； 根据哈希值的匹配情况， 将定时任务分别分配给工作机； 策略2， 分布式设置的工作机按照预设顺序要求发起心跳服务， 第一个回应的工作机选 定为执行定时任务的工作机； 策略3， 将定时任务调度分配给 预设时间段内使用次数最少的工作机； 策略4， 将定时任务调度分配给距离上一次执 行定时任务时间最久的工作机； 策略5， 将定时任务调度分配给忙碌分数最小的工作机； 所述忙碌分数由工作机的中央 处理器占用情况和已分配待执 行的任务数量进行加权计算得到 。 7.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述实 现分布式调度后， 还 包括： 任务再调度； 所述任务再调度的步骤 包括： (1)对于已经调度而未运行的任务批次， 获取 再分配任务批次集 合和工作机列表； (2)基于步骤(1)获取的工作机列表， 将每个工作机的忙碌分数与预设阈值比较， 获得 空闲工作机列表； 所述忙碌 分数由工作机的中央处理器占用情况和已分配待 执行的任务数 量进行加权计算得到；权　利　要　求　书 1/3 页 2 CN 114968557 A 2(3)遍历所述再分配任务批次集 合， 基于所述空 闲工作机列表， 实现任务再调度。 8.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述分 别分配给 预选取的分布式设置的工作机进行 执行中， 执行时还包括： 工作机宕机检测。 9.根据权利要求1所述的一种用于电力行业定时任务调度的方法， 其特征在于， 所述分 别分配给 预选取的分布式设置的工作机进行 执行中， 执行时还包括： 任务异常中断检测。 10.一种用于电力行业定时任务调度的系统， 其特 征在于， 包括： 任务批次生成模块， 用于获取待调度的 电力行业定时任务， 基于电力行业定时任务的 属性信息生成多个任务批次； 状态检查模块， 用于周期性检查每个任务批次中每个定时任务的依赖状态和超时状 态， 获得依赖状态检查结果和超时状态检查结果； 调度执行模块， 用于将依赖状态检查结果和超时状态检查结果均符合预设要求的任务 批次中的定时任务， 分别分配给 预选取的分布式设置的工作机进行 执行， 实现分布式调度。 11.根据权利要求10所述的一种用于电力行业定时任务调度的系统， 其特征在于， 所述 状态检查模块中， 依赖状态检查包括路径依赖检查、 第三方依赖检查和逻辑依赖检查中的 一种或多种。 12.根据权利要求10所述的一种用于电力行业定时任务调度的系统， 其特征在于， 所述 状态检查模块中， 超时状态检查包括依赖超时检查和产出超时检查中的一种或两种。 13.根据权利要求10所述的一种用于电力行业定时任务调度的系统， 其特征在于， 所述 调度执行模块中， 将依赖状态检查结果和超时状态检查结果均符合预设要求的任务批次中 的定时任务， 分别分配给预选取 的分布式设置的工作机进行执行， 实现分布式调度的步骤 具体包括： 采用策略1至策略5 中的一种或多种， 将依赖状态检查结果和超时状态检查结果均符合 预设要求的任务批次中的定时任务， 分别分配给 预选取的分布式设置的工作机； 分配定时任务的工作机基于数据库锁的方式， 上报取得触发器后执行分配的定时任 务； 其中， 策略1， 通过乘以固定值再求模最后取特定位数的方式， 分别获得每个定时任务 编号和工作机编号的哈希值； 根据哈希值的匹配情况， 将定时任务分别分配给工作机； 策略2， 分布式设置的工作机按照预设顺序要求发起心跳服务， 第一个回应的工作机选 定为执行定时任务的工作机； 策略3， 将定时任务调度分配给 预设时间段内使用次数最少的工作机； 策略4， 将定时任务调度分配给距离上一次执 行定时任务时间最久的工作机； 策略5， 将定时任务调度分配给忙碌分数最小的工作机； 所述忙碌分数由工作机的中央 处理器占用情况和已分配待执 行的任务数量进行加权计算得到 。 14.根据权利要求10所述的一种用于电力行业定时任务调度的系统， 其特征在于， 所述 调度执行模块中， 实现分布式调度后， 还 包括： 任务再调度； 所述任务再调度的步骤 包括： (1)对于已经调度而未运行的任务批次， 获取 再分配任务批次集 合和工作机列表；权　利　要　求　书 2/3 页 3 CN 114968557 A 3