(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211112639.X (22)申请日 2022.09.13 (71)申请人 国能信控互联技 术有限公司 地址 102209 北京市昌平区未来科技城英 才北二街9号国电新能源院301号楼6 层618、 619号房间 (72)发明人 武高峰　吉云　吴菲　程睿君　 (74)专利代理 机构 北京智绘未来专利代理事务 所(普通合伙) 11689 专利代理师 肖继军 (51)Int.Cl. G06F 8/60(2018.01) G06F 8/65(2018.01) G06F 9/48(2006.01) G06F 9/50(2006.01)G06F 9/54(2006.01) G06F 16/25(2019.01) (54)发明名称 一种针对电力时序数据的分布式计算系统 及其实现方法 (57)摘要 本发明是一种针对电力时序数据的分布式 计算系统及其实现方法， 该系统包括Web管理模 块， 用于资源监控、 策略配置和作业管理； Server 控制模块， 用于分发作业指令、 接受并分析作业 日志、 监测计算机资源状态和负载均衡； Agent 计 算模块， 用于接受作业指令并调用处理电力时序 数据的计算程序， 执行作业， 能够采集作业日志 和硬件资源使用信息并传输至Server控制模块； Web管理模 块、 Server控制模 块和Agent计算模 块 均部署于计算机上， Sever控制模块通过消息中 间件分别与Web管理模块和Agent计算模块进行 连接。 本发明能够有效提升数据计算效率， 对计 算资源进行扩展并能进行有效的监控， 并对任务 执行过程进行监控， 实现计算资源的有效利用和 并行计算， 提高计算机资源 使用率和计算效率。 权利要求书3页 说明书9页 附图2页 CN 115543345 A 2022.12.30 CN 115543345 A 1.一种针对电力时序数据的分布式计算系统， 其特 征在于， 该系统包括： Web管理模块， 用于资源监控、 策略配置和作业管理； Server控制模块， 用于分发作业指令、 接受并分析作业日志、 监测计算机资源状态和负 载均衡； Agent计算模块， 用于接受作 业指令并调用计算程序执行作业， 能够采集作业日志和硬 件资源使用信息并传输 至Server控制模块； Web管理模块、 Server控制模块和Agent计算模块均 部署于计算机上， Sever控制模块通 过消息中间件， 分别与Web管理模块和Agent计算模块进行连接， 且Web管理模块、 Server控 制模块和Agent计算模块的数据存储于数据存储模块中， Agent计算模块调用的计算程序为 用于处理电力时序数据的计算 程序。 2.根据权利要求1所述的针对电力时序数据的分布式计算系统， 其特 征在于， Web管理模块还包括资源管理子系统、 作业管理子系统、 执行历史子系 统， 且资源管理 子系统、 作业管理子系统和执 行历史子系统分别设置可视化界面； 资源管理子系统， 用于计算机的手动注 册、 信息维护、 分组管理； 作业管理子系统， 用于作业管理配置， 包括 新增作业、 作业启停、 批量作业 导入； 执行历史子系统， 用于展示作业执 行记录， 包作业执 行时间、 执 行状态、 执 行分析结果。 3.根据权利要求2所述的针对电力时序数据的分布式计算系统， 其特 征在于， Server控制模块还包括指令发送子系统， Server控制模块根据Web管理模块的作业管 理子系统配置的作业参数、 启停指令生成新的作业指令集， 并通过指令发送子系统进行作 业指令分发， 将作业指令发送至消息中间件。 4.根据权利要求1所述的针对电力时序数据的分布式计算系统， 其特 征在于， Server控制模块还包括日志分析子系统， 日志分析子系统通过消息中间件接收Agent 计算模块发送的作业执 行日志， 并分析作业执 行日志， 将分析 结果存储于数据存 储模块中。 5.根据权利要求3所述的针对电力时序数据的分布式计算系统， 其特 征在于， Server控制模块能够在多台计算机上分布式安装部署， 用于在Server控制模块的工作 中实现负载均衡。 6.根据权利要求5所述的针对电力时序数据的分布式计算系统， 其特 征在于， Server控制模块还包括资源状态监测子系统， 资源状态监测子系统包括状态监听程序 和资源实时更新 程序； 状态监听程序通过程序协调服务实时监听计算机， 即状态监听程序监听Server控制模 块或Agent计算模块所安装的计算机， 并执 行更新逻辑； 资源实时更新程序， 通过消息中间件接收Agent计算模块发送的计算机硬件资源使用 信息。 7.根据权利要求3所述的针对电力时序数据的分布式计算系统， 其特 征在于， Server控制模块还包括负载均衡子系统， 负载均衡子系 统支持包括加权轮询、 顺序分 配、 按CPU优 先、 按内存优 先的负载均衡策略， 并能够依据作业设置策略， 选择和分配作业执 行的计算机； 其中， 加权轮询策略包括： 根据计算机设置的权 重值， 按照权 重值由大到小 进行分配； 顺序分配策略包括： 根据计算机注 册顺序进行分配；权　利　要　求　书 1/3 页 2 CN 115543345 A 2按CPU优先策略包括： 根据计算机CPU资源剩余占比大小进行分配， 较高的剩余占比则 优先分配； 按内存优先策略包括： 根据计算机内存剩余占比大小进行分配， 较高的剩余占比则优 先分配。 8.根据权利要求1所述的针对电力时序数据的分布式计算系统， 其特 征在于， Agent计算模块能够安装部署在多台计算机器上， Agent计算模块在首 次安装时通过程 序协调服 务主动向Server控制模块注 册； 安装Agent计算模块的计算机是Server控制模块资源状态监测子系统的监听对象。 9.根据权利要求3所述的针对电力时序数据的分布式计算系统， 其特 征在于， Agent计算模块还包括计算引擎调度子系统， 通过计算引擎调度子系 统接收消息中间 件传递的作业指令并执 行作业； 计算引擎调度子系统通过消息中间件， 接收Server控制模块的指令发送子系统发送的 指令， 根据指令信息适配 计算引擎、 调用启动计算 程序和执 行作业。 10.根据权利要求9所述的针对电力时序数据的分布式计算系统， 其特 征在于， Agent计算模块还包括日志采集子系 统， 日志采集子系统负责收集作业执行过程产生 的日志， 通过消息中间件传输给Server控制模块， Server控制模块能够分析存 储日志记录。 11.根据权利要求9所述的针对电力时序数据的分布式计算系统， 其特 征在于， Agent计算模块还包括硬件资源监控子系统， 硬件资源监控子系统使用硬件设备监控 服务， 监控采集运行环境硬件资源使用信息， 并能通过消息中间件传输给Server控制模块。 12.一种根据所述权利要求1～11任意一项针对电力时序数据的分布式计算系统的针 对电力时序数据的分布式计算系统实现方法， 其特 征在于， 该 方法包括以下步骤： 步骤1， 安装Server控制模块的计算机和安装Agent计算模块的计算机向程序协调服务 进行注册； 步骤2， Server控制模块资源状态监控子系 统分别判断发起注册的计算机是否已被接 管， 是则转到步骤四； 步骤3， 存 储计算机信息， Server控制模块接管 该计算机； 步骤4， Agent计算模块硬件资源管理子系统， 采集Agent计算模块运行环境硬件资源信 息， 并发送到消息中间件； 步骤5， Server控制模块资源状态监测子系统， 通过程序协调服务传和消息中间件， 实 时获取安装Agent计算模块计算机在线状态以及硬件资源使用信息， 并更新到数据存储模 块中； 步骤6， Web管理模块的作业管理子系 统发起作业指令， 将作业指令信息存储到数据存 储模块中， 同时将指令信息发送到消息中间件中； 步骤7， Server控制模块接收消息中间件传递的指令信息， 负载均衡子系统和 指令发送 子系统根据指令信息， 生成新的指令信息， 并发送到消息中间件； 步骤8， Agent计算模块计算引擎调度子系统通过消息中间件接收指令信息， 根据指令 信息适配 计算引擎， 调用启动用于处 理电力时序数据的计算 程序， 执行作业； 步骤9， 日志采集子系统监控作业执 行过程， 将采集到的执 行日志发送消息中间件； 步骤10， Server控制模块日志分析子系统通过消息中间件， 接收该作 业执行日志， 分析权　利　要　求　书 2/3 页 3 CN 115543345 A 3