[發(fā)明專利]一種電能質(zhì)量數(shù)據(jù)的融合方法、裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201810368579.5
• 申請日: 2018-04-23
• 公開（公告）號: CN108805741B
• 公開（公告）日: 2022-02-11
• 發(fā)明（設(shè)計(jì)）人: 丁澤俊;王昕;劉桓瑞;龐雪燕;陳曉國;王英潔;周聰
• 申請（專利權(quán)）人: 南方電網(wǎng)科學(xué)研究院有限責(zé)任公司;深圳市中電電力技術(shù)股份有限公司
• 主分類號: G06Q50/06
• 分類號: G06Q50/06
• 代理公司: 深圳中一專利商標(biāo)事務(wù)所 44237
• 代理人: 陳宇

一種電能質(zhì)量數(shù)據(jù)的融合方法包括：電能質(zhì)量監(jiān)測點(diǎn)采集電能質(zhì)量數(shù)據(jù)，根據(jù)訂閱指令將所述電能質(zhì)量數(shù)據(jù)實(shí)時(shí)發(fā)送至kafka服務(wù)器；Kafka服務(wù)器接收數(shù)據(jù)WEB客戶端的數(shù)據(jù)消費(fèi)請求；所述kafka服務(wù)器根據(jù)所述WEB客戶端的數(shù)據(jù)消費(fèi)記錄，查找所述WEB客戶端的數(shù)據(jù)消費(fèi)請求所對應(yīng)的偏移量，從所述kafka服務(wù)器獲取所述偏移量對應(yīng)的電能質(zhì)量數(shù)據(jù)，并發(fā)送給所述WEB客戶端。通過kafka服務(wù)器進(jìn)行數(shù)據(jù)的中轉(zhuǎn)，使得不同系統(tǒng)的電能質(zhì)量數(shù)據(jù)能夠得到有效的融合，并且通過kafka服務(wù)器響應(yīng)偏移量，能夠更為實(shí)時(shí)的響應(yīng)WEB客戶端的電能質(zhì)量數(shù)據(jù)請求。

技術(shù)領(lǐng)域

本發(fā)明屬于電能質(zhì)量數(shù)據(jù)處理領(lǐng)域，尤其涉及一種電能質(zhì)量數(shù)據(jù)的融合方法、裝置及系統(tǒng)。

背景技術(shù)

隨著智能電網(wǎng)的不斷發(fā)展，以及人們對電能質(zhì)量越來越重視，使得現(xiàn)今的電能質(zhì)量數(shù)據(jù)海量增加。由于電能質(zhì)量數(shù)據(jù)的迅速增長，對所述電能質(zhì)量數(shù)據(jù)進(jìn)行監(jiān)測的電能質(zhì)量監(jiān)測系統(tǒng)也不斷增加。

由于不同的監(jiān)測系統(tǒng)通常采用不同的數(shù)據(jù)庫來存儲數(shù)據(jù)，不同系統(tǒng)在運(yùn)行環(huán)境(例如計(jì)算機(jī)操作系統(tǒng)、數(shù)據(jù)庫系統(tǒng)、信息安全分區(qū)等)、網(wǎng)絡(luò)結(jié)構(gòu)和協(xié)議、數(shù)據(jù)模型、物理模型、數(shù)據(jù)語義等方面均存在顯著差異。因此，對于海量的電能質(zhì)量數(shù)據(jù)，不能有效的在不同的監(jiān)測系統(tǒng)之間進(jìn)行管理和傳輸，電能監(jiān)測數(shù)據(jù)融合的難度較大。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明實(shí)施例提供了一種電能質(zhì)量數(shù)據(jù)的融合方法、裝置及系統(tǒng)，以解決現(xiàn)有技術(shù)中對于海量的電能質(zhì)量數(shù)據(jù)，不能有效的在不同的監(jiān)測系統(tǒng)之間進(jìn)行管理和傳輸，電能監(jiān)測數(shù)據(jù)融合的難度較大的問題。

本發(fā)明實(shí)施例的第一方面提供了一種電能質(zhì)量數(shù)據(jù)的融合方法，所述電能質(zhì)量數(shù)據(jù)的融合方法包括：

電能質(zhì)量監(jiān)測點(diǎn)采集電能質(zhì)量數(shù)據(jù)，根據(jù)訂閱指令將所述電能質(zhì)量數(shù)據(jù)實(shí)時(shí)發(fā)送至kafka服務(wù)器；

Kafka服務(wù)器接收數(shù)據(jù)WEB客戶端的數(shù)據(jù)消費(fèi)請求；

所述kafka服務(wù)器根據(jù)所述WEB客戶端的數(shù)據(jù)消費(fèi)記錄，查找所述WEB客戶端的數(shù)據(jù)消費(fèi)請求所對應(yīng)的偏移量，從所述kafka服務(wù)器獲取所述偏移量對應(yīng)的電能質(zhì)量數(shù)據(jù)，并發(fā)送給所述WEB客戶端。

結(jié)合第一方面，在第一方面的第一種可能實(shí)現(xiàn)方式中，所述電能質(zhì)量監(jiān)測終端采集電能質(zhì)量數(shù)據(jù)，根據(jù)訂閱指令將所述電能質(zhì)量數(shù)據(jù)實(shí)時(shí)發(fā)送至kafka服務(wù)器的步驟包括：

通過電能質(zhì)量監(jiān)測點(diǎn)實(shí)時(shí)采集電能質(zhì)量數(shù)據(jù)；

通過WEB服務(wù)接口接收到kafka服務(wù)器發(fā)送的訂閱指令；

將電能質(zhì)量數(shù)據(jù)封裝到消息中并實(shí)時(shí)發(fā)送至kafka服務(wù)器，所述kafka服務(wù)器接收到消息進(jìn)行解封裝得到電能質(zhì)量數(shù)據(jù)，并確定所接收的電能質(zhì)量數(shù)據(jù)的偏移量。

結(jié)合第一方面，在第一方面的第二種可能實(shí)現(xiàn)方式中，所述確定所接收的電能質(zhì)量數(shù)據(jù)的偏移量的步驟包括：

將所述電能質(zhì)量數(shù)據(jù)發(fā)送到指定主題和分區(qū)；

以指定主題和分區(qū)的末尾的偏移量為基礎(chǔ)，確定所述電能質(zhì)量數(shù)據(jù)的偏移量。

結(jié)合第一方面、第一方面的第一種可能實(shí)現(xiàn)方式、第一方面的第二種可能實(shí)現(xiàn)方式，在第一方面的第三種可能實(shí)現(xiàn)方式中，所述方法還包括：

通過kafka服務(wù)器集群的方式，將所電能質(zhì)量數(shù)據(jù)以及對應(yīng)的偏移量進(jìn)行冗余備份；

根據(jù)kafka服務(wù)器中的分區(qū)的服務(wù)狀態(tài)，確定kafka服務(wù)器集群中的kafka服務(wù)器為WEB客戶端提供服務(wù)。

結(jié)合第一方面，在第一方面的第四種可能實(shí)現(xiàn)方式中，所述方法還包括：

所述kafka服務(wù)器根據(jù)預(yù)定的緩存策略，按照電能質(zhì)量數(shù)據(jù)的存儲順序，將較先存儲的電能質(zhì)量數(shù)據(jù)刪除。