-
公开(公告)号:CN116594988A
公开(公告)日:2023-08-15
申请号:CN202211344591.5
申请日:2022-10-31
申请人: 国网冀北电力有限公司 , 北京科东电力控制系统有限责任公司
IPC分类号: G06F16/215 , G06F16/22 , G06F16/25 , G06F16/28
摘要: 本发明公开了一种基于消息总线的数据汇聚系统和方法,方法包括设置数据汇集任务的参数,根据参数生成各数据汇集任务;定义基于protobuf插件的消息报文格式并发布;根据所述任务配置模块生成的数据汇集任务,从源端地址中抽取数据,根据数据汇聚任务中设置的转换方式将数据转换为接收端能够识别的格式和内容;调用protobuf插件提供的接口将数据填充到消息报文名称对应的消息报文中,调用消息总线接口将消息报文发送至总线集群;调用消息总线接口从总线集群接收消息报文,将消息报文反序列化,按照消息报文的定义解析消息报文内容。本发明可以提高异构系统之间的数据汇集效率,减少重复开发成本,具有很强的实用性。