(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210953716.8 (22)申请日 2022.08.10 (71)申请人 浪潮软件科技有限公司 地址 250100 山东省济南市高新区浪潮路 1036号浪潮科技园 (72)发明人 于春蕾　朱家兵　蔡军凯　房爱印　 尹曦萌　 (74)专利代理 机构 济南信达专利事务所有限公 司 37100 专利代理师 潘悦梅 (51)Int.Cl. G06F 17/18(2006.01) G06F 16/2458(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) (54)发明名称 基于Flink的站点滑动降雨量累积实时计算 方法及系统 (57)摘要 本发明公开了基于Flink的站点滑动降雨量 累积实时计算方法及系统， 属于数据处理技术领 域， 要解决的技术问题为如何准确快速的计算累 计降雨量， 并提高站点累计降雨的计算频次。 包 括如下步骤： 对于各个雨量监测站 基于预定频率 定时上报雨量监测数据， 通过Flink的连接器接 入每个雨量监测站上报的雨量监测数据， 并对雨 量监测数据进行解析得到雨量监测值； 通过 Flink分布式计算每个雨量监测站在各个预定长 度时间段的滑动降雨累积量； 将每个雨量监测站 在各个预定长度时间段的滑动降雨累积量存储 至数据库； 通过Flink提供的界面展示每个雨量 监测站在各个预定长度时间段的滑动降雨累积 量， 并提供滑动降雨累积量 查询。 权利要求书2页 说明书5页 附图1页 CN 115438304 A 2022.12.06 CN 115438304 A 1.一种基于Fl ink的站点滑动降雨 量累积实时计算方法， 其特 征在于， 包括如下步骤： 对于各个雨量监测站基于预定频率定时上报雨量监测数据， 通过Flink的连接器接入 每个雨量监测站上报的雨 量监测数据， 并对雨 量监测数据进行解析 得到雨量监测值； 基于各个雨量监测站对应的雨量监测值， 通过Flink分布式计算每个雨量监测站在各 个预定长度时间段的滑动降雨累积量； 将每个雨量监测站在各个预定 长度时间段的滑动降雨累积量存 储至数据库； 通过Flink提供的界面展示每个雨量监测站在各个预定长度时间段的滑动降雨累积 量， 并提供每 个雨量监测站在各个预定 长度时间段的滑动降雨累积量 查询。 2.根据权利要求1所述的基于Flink的站点滑动降雨量累积实时计算方法， 其特征在 于， 通过Flink的连接器接入每个雨量监测站上报的雨量监测数据之前， 通过Flink提供的 流数据Datast ream API或Batc h Processing API获取执行环境。 3.根据权利要求1所述的基于Flink的站点滑动降雨量累积实时计算方法， 其特征在 于， 所述雨量监测数据为报文格式； 通过Flink的连接器接入每个雨量监测站上报的雨量监测数据后， 基于报文解析协议 对雨量监测数据进行解析 得到雨量监测值。 4.根据权利要求1所述的基于Flink的站点滑动降雨量累积实时计算方法， 其特征在 于， 将每个雨量监测站在各个预定长度时间段的滑动降雨累积量存储至数据库之前， Flink 基于Sink方法与数据库建立连接 。 5.根据权利要求1所述的基于Flink的站点滑动降雨量累积实时计算方法， 其特征在 于， 还包括如下步骤： 基于每个雨量监测站在各个预定长度时间段的滑动降雨累积量， 生成各个雨量监测 站 的单日降雨累计曲线， 并通过 Flink提供的界面展示各个雨 量监测站的单日降雨累计曲线。 6.一种基于Flink的站点滑动降雨量累积实时计算系统， 其特征在于， 用于通过如权利 要求1‑5任一项所述的一种基于Flink的站点滑动降雨量累积实时计算方法计算各个雨量 监测站的滑动降雨累积量， 所述系统包括： 数据库； Flink， 所述Fl ink通过界面与用户交 互， 用于执 行： 对于各个雨量监测站基于预定频率定时上报雨量监测数据， 通过连接器接入每个雨量 监测站上报的雨 量监测数据， 并对雨 量监测数据进行解析 得到雨量监测值； 基于各个雨量监测站对应的雨量监测值， 分布式计算每个雨量监测站在各个预定长度 时间段的滑动降雨累积量； 将每个雨量监测站在各个预定 长度时间段的滑动降雨累积量存 储至数据库； 通过界面展示每个雨量监测 站在各个预定长度时间段的滑动降雨累积量， 并提供每个 雨量监测站在各个预定 长度时间段的滑动降雨累积量 查询。 7.根据权利要求6所述的基于Flink的站点滑动降雨量累积实时计算系统， 其特征在 于， 所述Flink通过连接器接入每个雨量监测站上报的雨量监测数据之前， 用于通过流数据 Datastream API或Batc h Processing API获取执行环境。 8.根据权利要求6所述的基于Flink的站点滑动降雨量累积实时计算系统， 其特征在 于， 所述雨量监测数据为报文格式；权　利　要　求　书 1/2 页 2 CN 115438304 A 2所述Flink通过连接器接入每个雨量监测站上报的雨量监测数据后， 用于基于报文解 析协议对雨 量监测数据进行解析 得到雨量监测值。 9.根据权利要求6所述的基于Flink的站点滑动降雨量累积实时计算系统， 其特征在 于， 将每个雨量监测站在各个预定长度时间段的滑动降雨累积量存储至数据库之前， 所述 Flink用于基于Si nk方法与数据库建立连接 。 10.根据权利要求6所述的基于Flink的站点滑动降雨量累积实时计算系统， 其特征在 于， 所述Fl ink还用于执 行： 基于每个雨量监测站在各个预定长度时间段的滑动降雨累积量， 生成各个雨量监测 站 的单日降雨累计曲线， 并通过界面展示各个雨 量监测站的单日降雨累计曲线。权　利　要　求　书 2/2 页 3 CN 115438304 A 3