[發(fā)明專利]一種氣象大數(shù)據(jù)處理調(diào)度系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110033717.6
• 申請(qǐng)日: 2021-01-12
• 公開(kāi)（公告）號(hào): CN112765294A
• 公開(kāi)（公告）日: 2021-05-07
• 發(fā)明（設(shè)計(jì)）人: 郭辰;田曉波;楊萍;張曉朝;梁思超;卜照軍;馮笑丹;王森;蔣賁;王志勇
• 申請(qǐng)（專利權(quán)）人: 華能新能源股份有限公司;北京朗潤(rùn)知天科技有限公司;華能集團(tuán)技術(shù)創(chuàng)新中心有限公司;中國(guó)華能集團(tuán)清潔能源技術(shù)研究院有限公司
• 主分類號(hào): G06F16/29
• 分類號(hào): G06F16/29;G06F16/27;G06F16/22;G06F16/2455
• 代理公司: 北京挺立專利事務(wù)所(普通合伙) 11265
• 代理人: 余瑩

1.一種氣象大數(shù)據(jù)處理調(diào)度系統(tǒng)，其特征是：包括數(shù)據(jù)生產(chǎn)者模塊，數(shù)據(jù)消費(fèi)者模塊，數(shù)據(jù)集市模塊，數(shù)據(jù)調(diào)度模塊以及GIS檢索模塊；所述數(shù)據(jù)生產(chǎn)者模塊，數(shù)據(jù)消費(fèi)者模塊，數(shù)據(jù)集市模塊，數(shù)據(jù)調(diào)度模塊以及GIS檢索模塊之間通過(guò)消息總線通信；

所述數(shù)據(jù)生產(chǎn)者模塊用于將數(shù)據(jù)生產(chǎn)者產(chǎn)生的數(shù)據(jù)主題發(fā)布到數(shù)據(jù)集市模塊；

所述數(shù)據(jù)消費(fèi)者模塊用于將數(shù)據(jù)消費(fèi)者從訂閱的數(shù)據(jù)主題中提取數(shù)據(jù)；

所述數(shù)據(jù)集市模塊用于存儲(chǔ)各個(gè)數(shù)據(jù)主題，并對(duì)異構(gòu)系統(tǒng)之間的數(shù)據(jù)分區(qū)，同一數(shù)據(jù)主題的不同分區(qū)存儲(chǔ)在不同的節(jié)點(diǎn)，分區(qū)數(shù)據(jù)相互備份，保障數(shù)據(jù)安全的同時(shí)對(duì)外提供服務(wù)；

所述數(shù)據(jù)調(diào)度模塊用于各模塊控制數(shù)據(jù)的協(xié)同調(diào)度，采用AMQP協(xié)議根據(jù)路由規(guī)則將接收的數(shù)據(jù)信息發(fā)送到數(shù)據(jù)消費(fèi)者模塊；

所述GIS檢索模塊用于定位和提取多維度時(shí)空網(wǎng)格氣象數(shù)據(jù)，使用GeoJSON通過(guò)數(shù)據(jù)路由為網(wǎng)格氣象數(shù)據(jù)建立索引，索引進(jìn)入數(shù)據(jù)庫(kù)，數(shù)據(jù)分區(qū)進(jìn)入數(shù)據(jù)主題，業(yè)務(wù)系統(tǒng)輸入坐標(biāo)查詢數(shù)據(jù)索引，獲取主題原數(shù)據(jù)進(jìn)行數(shù)據(jù)提取。

2.根據(jù)權(quán)利要求1所述的一種氣象大數(shù)據(jù)處理調(diào)度系統(tǒng)，其特征在于：所述業(yè)務(wù)模塊訂閱與其相關(guān)的消息主動(dòng)從數(shù)據(jù)消費(fèi)者模塊拉取與之匹配的數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的一種氣象大數(shù)據(jù)處理調(diào)度系統(tǒng)，其特征在于：所述消息總線用于各模塊之間的數(shù)據(jù)轉(zhuǎn)發(fā)，消息總線內(nèi)部有多個(gè)流式通信管線構(gòu)成。

4.根據(jù)權(quán)利要求1所述的一種氣象大數(shù)據(jù)處理調(diào)度系統(tǒng)，其特征在于：所述AMQP協(xié)議從流式通信管線中根據(jù)同一主題數(shù)據(jù)進(jìn)行路由選擇，路由選擇方式包括數(shù)據(jù)優(yōu)先級(jí)別，數(shù)據(jù)類型，過(guò)濾數(shù)據(jù)或者插值訂正處理。