基于服务调用和消息队列的营配数据集成方法及实现

Design and Implementation of Marketing and Distribution Data Integration Based on Service Invocation and Message Queue

随着国家电网公司“建设具有中国特色国际领先的能源互联网企业”战略目标的推进,营配调数据贯通质量、调度运行感知能力面临着更高的要求。数据查询、实时数据发布是异构系统数据集成的需求;跨语言、跨平台交互是系统贯通面临的挑战。将面向服务调用的SOAP和REST融合,配合Kafka实时消息流发布订阅用于营配数据集成,可有效解决上述问题。清晰规范的自描述服务定义可减少接口联调时间,不依赖第三方服务框架,便于问题定位,提升稳定性。较低的系统介入程度,可降低改造复杂度。经现场工程测试验证,此方法实际有效地支撑了多省地营配系统贯通业务。

With the advancement of State Grid Corporation of China's strategic goal that"building an internationally leading energy internet enterprise with Chinese characteristics",the quality of data penetration and the perception of dispatch operations are facing higher requirements.Data query and real-time publishing are requirements for data integration of heterogeneous systems.Cross-language and cross-platform interaction are the challenges faced by system integration.The above problems can be effectively solved by integrating SOAP and REST with Kafka real-time message flow publishing and subscription for distribution data integration.The clear and standardized self-describing service definition can reduce the time of interface joint debugging,and does not rely on the third-party service framework,which is convenient for problem location and improves stability.The lower level of system intervention can reduce the complexity of transformation.It has been verified by on-site engineering tests that this method actually and effectively supports the operation of multi-province and local distribution systems.