一种基于信创环境的实时计算框架搭建方法

    公开(公告)号:CN118012383A

    公开(公告)日:2024-05-10

    申请号:CN202410026336.9

    申请日:2024-01-08

    IPC分类号: G06F8/20 G06F11/36 G06Q50/06

    摘要: 本发明提供一种基于信创环境的实时计算框架搭建方法,包括步骤:S101、搭建分布式环境,所述分布式环境基于流批一体处理框架的独立集群模式实现;S102、使用第一测试用例对分布式环境性能进行测试;S103、使用第二测试用例对分布式环境在大数据量的计算场景下的可靠性进行测试;S104、完成分布式环境对外公开的应用程序接口的抽象,从而提供针对静态批次数据、流式数据的数据操作功能;S105、基于配网的业务需求,在分布式环境中实现相应的业务功能。本发明以Apache Flink为实时计算框架基础,实现流批一体实时计算,优化、提升其应用容错能力,满足电网应用场景的低延时、高呑吐、高健壮等方面的要求。