基于流式计算的自动站资料实时处理系统研究

为解决自动气象站资料处理业务中存在的流程分散、处理统计时效性不足等问题,提出一种自动气象站资料实时处理系统的建设思路和方法。将自动气象站资料封装为消息,使用消息中间件进行数据传输,引入分布式流式计算引擎,利用基于现有的数据解码和统计算法,在流式计算框架内进行设计、重构和整合,将处理后的数据存储到分布式关系型数据库。结果表明,统一平台下的自动气象站资料接入和处理方法,能够使构建的系统具有较高的可靠性、低延迟和容错性等特点,满足自动气象站资料实时数据服务的时效性、准确性需求。