基于新疆智能网格强对流短时预报产品的集约化系统的设计与实现＊

肖俊安，芒苏尔·艾热提

（新疆维吾尔自治区气象台，新疆 乌鲁木齐 830002）

为适应气象预报业务智能精准、客观定量的发展要求，应推进研究型业务发展，激励广大研发人员和预报员积极开展预报技术方法研发和业务应用，促进预报关键技术突破和自主可控，提升预报技术的先进性和智能化水平，提高预报准确率，实现创新驱动气象预报高质量发展。开发智能网格业务系统已成为智能网格预报的优化方向之一，郑波等[1]分析了智能网格预报业务的特点，阐述了全国综合气象信息共享平台的精细化格点业务数据环境的数据流程、核心功能等相关技术。目前国内很多省份也都完成了个性化的智能网格预报平台的设计与实现[2-4]。本研究主体采用C/S 架构，监控模块采用B/S 架构，可以对每个环节生成的预报产品进行管理和监控。设计与实现基于新疆智能网格强对流短时预报产品的集约化系统，对今后的新疆智能网格强对流短时预报业务也具有较好的支撑作用。

1 新疆智能网格强对流短时预报产品介绍

新疆智能网格强对流短时预报产品中主要包含了3 个产品，即强降水预报产品、大风预报产品和雷暴预报产品。强降水预报产品是基于CLDAS 格点融合产品基础上对多个模式产品的检验加权分级订正后生成的，短时大风预报产品是利用CLDAS 格点融合产品和多模式的全格点滚动建模技术生成的，雷暴预报产品是主要基于高分辨率区域模式预报产品基础上进行概率模糊和动态取优方法后生成的。

本次强对流短时预报产品主要基于中国气象局下发的GRAPES-MESO-3KM 模式产品、新疆本地的DOGRAFS 模式产品和中亚睿图RMAPS 模式产品技术上制作产生的，综合利用了国内在新疆地区的主要模式产品，建立了时空统一的模式产品数据集。

新疆短时强降水预报产品和雷暴预报产品都是新研发产品，预估目标不低于所有模式预报准确率，大风预报产品目前要远高于模式预报产品准确率。

2 系统架构设计

基于新疆智能网格强对流短时预报产品的集约化系统的架构采取统一标准的设计原则，采用分层架构设计，自下而上依次是数据层、业务层，表现层。各层之间既相对独立又形成一个统一的整体，实现系统的高内聚、低耦合的特点。这样不仅有利于系统独立运行，同时也便于系统的维护和管理。系统整体架构设计如图1 所示。

图1 基于新疆智能网格强对流短时预报产品的集约化系统整体架构

数据层主要是由新疆多模式集成滚动订正的强对流预报技术方法生成的强对流初始产品、后处理产品和最终产品及备份报的本地存储。

业务层—逻辑是整个系统的核心组成部分，主要是针对一系列产品的业务操作逻辑。主要分为产品汇总模块、产品处理模块、流程调度模块、FTP 上传模块、产品压缩编码模块和备份报模块。

业务层—配置提供系统的管理和维护服务，包括起报时和路径信息的配置、短时强降水和大风的阈值配置、流程调度信息配置、FTP 上传信息配置、最终产品压缩编码信息配置和网络站点配置。系统通过结合环境变量和ConfigParser 库读取外部ini 配置文件内的多种参数来进行配置管理。

表现层主要是调用Rest 服务请求的接口，将数据层中产品明细和平台层中各模块的处理结果返回至前端，通过Javascript 脚本对返回信息处理生成监控流程和报警信息，将其渲染至网页上显示。

3 主要功能

新疆智能网格强对流短时预报集约化流程系统的主要功能设计包含系统运行、双备份报、调度管理、产品监控及信息展示5 个部分。

3.1 系统运行

3.1.1 资料及产品归档入库

为了后续对初始产品、后处理产品和最终产品的处理更加高效便捷，符合气象目录规范和使用习惯的统一存储就显得尤为重要。部分存储目录的结构如表1所示，目录结构共设置为4 个层级，分别是根目录和1、2、3 级子目录。其中根目录和1、2 级子目录都是固定目录，用于区分初始产品和最终产品以及各要素；3级子目录是可变的，根据产品日期YYYY/YYYYMM DD（4 位数年份/4 位数年份+2 位数月份+2 位数日期）和起报时HH（2 位数小时数）的变化建立，用于动态具体的归档产品。

表1 部分存储目录结构

3.1.2 强对流产品加工处理

使用Pandas 和Numpy 两种数学函数库对数据进行加工：对新疆智能网格降水格点产品进行范围切割、阈值筛选处理得到Micaps 第四类格式的强降水产品；对新疆智能网格阵风和闪电格点预报产品进行阈值筛选后，分别得到由值为1（有）和0（无）构成的大风和闪电预报，通过二者对应格点数值相交，得到Micaps第四类格式的雷暴大风格点预报产品。对强降水和雷暴大风预报产品进行插值处理，得到乌鲁木齐市站单站强对流精细化报文。对强降水和雷暴大风预报的Micaps 文件进行压缩编码，打包生成符合竞赛标准的Grib2 文件格式的产品，并汇总在Final_Product 对应要素的目录中，等待FTP 程序自动上传至竞赛服务器。

3.1.3 产品推送

对最终产品路径里符合命名规范的各类文件列表快速检索，根据产品名称中的关键字、日期和存储格式，通过FTP 的方式，动态地将产品推送到竞赛服务器对应目录中。

3.2 双备份报

由于此次竞赛规则中有一项主要考察各参赛队上传的参赛预报技术方法生成预报产品的稳定性和到报及时率，为了避免出现服务器故障或其他不可抗力导致强对流产品无法按时生成的情况，系统采用了双份备份报机制，2 份备份报最终都会推送至信息中心竞赛服务器。如果到上传中国气象局时间点正式产品仍未生成，则自动优先上传订正备份报，如果订正备份报也未生成，则上传基础备份报。

3.2.1 生成基础备份报

强对流服务器上部署了一套基础备份报生成程序。每天17：00 基础备份报生成程序将固定的无强降水、无雷暴大风的Micaps 模板文件名和内容中的日期替换成次日的，经过压缩编码后一次性生成次日的所有产品。

3.2.2 生成订正备份报

备份服务器上部署了一套订正备份报生成程序。订正备份报则在正式产品上传前一小时生成。订正备份报采用中国气象局下发的全国强降水和雷暴大风指导产品作为基础预报产品，在此之上进行新疆区域范围裁剪及质控，再进行压缩编码后生成。

3.3 调度管理

3.3.1 系统运行流程调度

分别在01：00—01：30、07：00—07：30、13：00—13：30、19：00—19：30 这4 个时间段每分钟并行执行资料及产品归纳入库、产品加工处理、强对流产品压缩编码、最终产品推送4 个子程序。

3.3.2 双备份报生成调度

基础备份报调度：每日17：00 执行次日的强对流模板压缩编码、最终备份报推送2 个子程序。

订正备份报调度：分别在00：00—01：30、06：30—07：30、12：30—13：30、18：30—19：30这4 个时间段每分钟并行执行中国气象局下发的全国强降水和雷暴大风指导产品归纳入库、产品加工处理、强对流产品压缩编码、最终订正备份报推送4 个子程序。

3.4 产品监控及信息可视化

为方便管理人员对产品状态有直观的了解，配合Django 框架快速开发了新疆智能网格强对流竞赛产品监控模块。该模块实现一个简单的单页面应用，模块的查询接口采用RESTful 架构开发，遵循RESTful API规范。用户在模块网页前端选取日期和起报时等接口参数，点击查询后，访问URL 接口调用后端的监控服务逻辑，将结果以JSON 的格式返回至前端渲染，管理人员可以清晰看到每次产品生成、推送的状态和数量，及时发现问题的所在。

4 结束语

基于新疆智能网格强对流短时预报产品的集约化系统对新疆智能网格强对流短时预报产品的定时汇总、处理、上传、监控等流程进行了统一的管理，各环节有序衔接。系统自投入使用以来，整体运行高效稳定，确保了竞赛产品完整准时地上传中国气象局。目前系统在功能完整性方面还存在不足，例如Web 监控应用的后端逻辑尚未接入产品就位时间和系统报错日志等信息。后期还需要继续在产品监控和故障告警等功能方面进行完善和升级，为新疆智能网格强对流短时预报产品的集约化管理提供更好的支撑作用。