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

有效

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

1.一種電能質(zhì)量數(shù)據(jù)的融合方法，其特征在于，所述電能質(zhì)量數(shù)據(jù)的融合方法包括：

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

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

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

其中，所述kafka服務(wù)器包括多個(gè)服務(wù)器構(gòu)成的服務(wù)器集群，多個(gè)服務(wù)器包括主服務(wù)器和備用服務(wù)器，在不同的服務(wù)器上備份有相同的電能質(zhì)量數(shù)據(jù)以及電能質(zhì)量數(shù)據(jù)對(duì)應(yīng)的偏移量，當(dāng)kafka服務(wù)器接收到數(shù)據(jù)需求時(shí)，根據(jù)偏移量查找對(duì)應(yīng)的類別和分區(qū)，判斷該分區(qū)是否正在提供數(shù)據(jù)傳輸服務(wù)，通過空閑狀態(tài)的類別和分區(qū)，為WEB客戶端提供數(shù)據(jù)傳輸服務(wù)。

2.根據(jù)權(quán)利要求1所述的電能質(zhì)量數(shù)據(jù)的融合方法，其特征在于，所述電能質(zhì)量監(jiān)測(cè)點(diǎn)采集電能質(zhì)量數(shù)據(jù)，根據(jù)訂閱指令將所述電能質(zhì)量數(shù)據(jù)實(shí)時(shí)發(fā)送至kafka服務(wù)器的步驟包括：

通過電能質(zhì)量監(jiān)測(cè)點(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ù)的偏移量。

3.根據(jù)權(quán)利要求2所述的電能質(zhì)量數(shù)據(jù)的融合方法，其特征在于，所述確定所接收的電能質(zhì)量數(shù)據(jù)的偏移量的步驟包括：

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

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

4.根據(jù)權(quán)利要求1-3任一項(xiàng)所述的電能質(zhì)量數(shù)據(jù)的融合方法，其特征在于，所述方法還包括：

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

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

5.根據(jù)權(quán)利要求1所述的電能質(zhì)量數(shù)據(jù)的融合方法，其特征在于，所述方法還包括：

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

6.一種電能質(zhì)量數(shù)據(jù)的融合裝置，其特征在于，所述電能質(zhì)量數(shù)據(jù)的融合裝置包括：

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

消費(fèi)請(qǐng)求接收單元，用于由Kafka服務(wù)器接收數(shù)據(jù)WEB客戶端的數(shù)據(jù)消費(fèi)請(qǐng)求；

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

其中，所述kafka服務(wù)器包括多個(gè)服務(wù)器構(gòu)成的服務(wù)器集群，多個(gè)服務(wù)器包括主服務(wù)器和備用服務(wù)器，在不同的服務(wù)器上備份有相同的電能質(zhì)量數(shù)據(jù)以及電能質(zhì)量數(shù)據(jù)對(duì)應(yīng)的偏移量，當(dāng)kafka服務(wù)器接收到數(shù)據(jù)需求時(shí)，根據(jù)偏移量查找對(duì)應(yīng)的類別和分區(qū)，判斷該分區(qū)是否正在提供數(shù)據(jù)傳輸服務(wù)，通過空閑狀態(tài)的類別和分區(qū)，為WEB客戶端提供數(shù)據(jù)傳輸服務(wù)。

7.根據(jù)權(quán)利要求6所述的電能質(zhì)量數(shù)據(jù)的融合裝置，其特征在于，所述訂閱數(shù)據(jù)發(fā)送單元包括：

采集子單元，用于通過電能質(zhì)量監(jiān)測(cè)點(diǎn)實(shí)時(shí)采集電能質(zhì)量數(shù)據(jù)；

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

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