[發(fā)明專利]基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法

在審

• 申請?zhí)枺?/td>: 201710099461.2
• 申請日: 2017-02-23
• 公開（公告）號: CN106777392A
• 公開（公告）日: 2017-05-31
• 發(fā)明（設(shè)計(jì)）人: 孫立華;胡牧;孟慶強(qiáng);李端超;王松;黃太貴;黃少雄;王正風(fēng);程栩
• 申請（專利權(quán)）人: 國家電網(wǎng)公司;南京南瑞集團(tuán)公司;南京南瑞信息通信科技有限公司;國網(wǎng)安徽省電力公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;F03D17/00
• 代理公司: 南京縱橫知識產(chǎn)權(quán)代理有限公司32224
• 代理人: 董建林,閆方圓

1.基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：包括以下步驟，

步驟（A），接收風(fēng)機(jī)機(jī)組scada數(shù)據(jù)；

步驟（B），去除重復(fù)數(shù)據(jù)：解析每臺風(fēng)機(jī)機(jī)組每秒鐘scada實(shí)時(shí)數(shù)據(jù)的斷面數(shù)據(jù)，并根據(jù)MD5算法對斷面數(shù)據(jù)進(jìn)行去重處理，將重復(fù)數(shù)據(jù)丟棄，且保證每個(gè)斷面數(shù)據(jù)只被處理一次；

步驟（C），數(shù)據(jù)標(biāo)準(zhǔn)化處理：對各個(gè)廠家除重復(fù)數(shù)據(jù)的scada實(shí)時(shí)數(shù)據(jù)作標(biāo)準(zhǔn)化處理，標(biāo)注化處理需要經(jīng)歷數(shù)據(jù)映射、度量處理、閾值處理三個(gè)單元，從而構(gòu)造統(tǒng)一的scada數(shù)據(jù)庫；

步驟（D），數(shù)據(jù)運(yùn)行狀態(tài)解析：在數(shù)據(jù)標(biāo)準(zhǔn)化處理同時(shí)，根據(jù)風(fēng)機(jī)運(yùn)行狀態(tài)判斷規(guī)則，對各個(gè)廠家除重復(fù)數(shù)據(jù)的scada實(shí)時(shí)數(shù)據(jù)進(jìn)行運(yùn)行狀態(tài)解析，得到風(fēng)機(jī)運(yùn)行狀態(tài)數(shù)據(jù)；

步驟（E），保存數(shù)據(jù)：對步驟（D）得到的風(fēng)機(jī)運(yùn)行狀態(tài)數(shù)據(jù)進(jìn)行保存，并將標(biāo)準(zhǔn)化處理后的scada數(shù)據(jù)庫內(nèi)的數(shù)據(jù)保存到分布式數(shù)據(jù)倉庫Hive中，并風(fēng)機(jī)運(yùn)行狀態(tài)數(shù)據(jù)中的額風(fēng)機(jī)運(yùn)行數(shù)據(jù)保存到關(guān)系數(shù)據(jù)庫mysql中；

步驟（F），診斷風(fēng)電機(jī)組的運(yùn)行狀態(tài)：根據(jù)保存數(shù)據(jù)，對風(fēng)電機(jī)組的運(yùn)行狀態(tài)發(fā)生故障時(shí)，進(jìn)行診斷。

2.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于： 步驟（A）接收風(fēng)機(jī)機(jī)組scada數(shù)據(jù)的過程如下：

（A1）風(fēng)機(jī)機(jī)組的運(yùn)行數(shù)據(jù)通過采集器存入分布式消息隊(duì)列kafaka中；

（A2）根據(jù)不同廠家的scada系統(tǒng)建立不同的消息主題，通過流計(jì)算引擎storm程序訂閱各主題消息，從而獲取scada系統(tǒng)的scada實(shí)時(shí)數(shù)據(jù)；

（A3）將獲取scada實(shí)時(shí)數(shù)據(jù)放置到復(fù)雜事件處理引擎esper中。

3.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：步驟（B）根據(jù)MD5算法對斷面數(shù)據(jù)進(jìn)行去重處理，將重復(fù)數(shù)據(jù)丟棄的過程如下：先對斷面數(shù)據(jù)中每一個(gè)測點(diǎn)進(jìn)行求MD5值，根據(jù)各個(gè)測點(diǎn)的MD5值，二次取MD5值，若二次取的MD5值重復(fù)，則判斷為重復(fù)數(shù)據(jù)，病將重復(fù)數(shù)據(jù)丟棄。

4.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：步驟（C）數(shù)據(jù)標(biāo)準(zhǔn)化處理中的數(shù)據(jù)映射單元的處理過程如下：根據(jù)scada實(shí)時(shí)測點(diǎn)數(shù)據(jù)的映射規(guī)則，建立標(biāo)準(zhǔn)化數(shù)據(jù)，映射規(guī)則存儲(chǔ)于配置庫中，通過復(fù)雜事件處理引擎esper的epl語句，執(zhí)行映射規(guī)則，將不同廠家的scada實(shí)時(shí)數(shù)據(jù)統(tǒng)一為標(biāo)準(zhǔn)化的測點(diǎn)數(shù)據(jù)。

5.根據(jù)權(quán)利要求4所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：所述數(shù)據(jù)映射單元的處理過程中對只有個(gè)別廠家才有的點(diǎn)位數(shù)據(jù)，置為空值。

6.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：步驟（C）數(shù)據(jù)標(biāo)準(zhǔn)化處理中的度量處理單元的處理過程如下：根據(jù)scada實(shí)時(shí)測點(diǎn)度量配置規(guī)則，通過復(fù)雜事件處理引擎esper的epl語句，解析度量配置規(guī)則，對不同廠家的scada實(shí)時(shí)數(shù)據(jù)同一度量單位。

7.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：步驟（C）數(shù)據(jù)標(biāo)準(zhǔn)化處理中的閾值處理單元的處理過程如下：根據(jù)scada實(shí)時(shí)測點(diǎn)閾值處理規(guī)則，對scada實(shí)時(shí)數(shù)據(jù)中會(huì)出現(xiàn)異常數(shù)值進(jìn)行過濾或規(guī)整處理，通過復(fù)雜事件處理引擎esper的epl語句解析閾值處理規(guī)則，和已配置的scada實(shí)時(shí)測點(diǎn)閾值區(qū)間進(jìn)行比較，將scada實(shí)時(shí)數(shù)據(jù)不在閾值區(qū)間的異常數(shù)據(jù)，處理成空值。

8.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于：步驟（D），根據(jù)風(fēng)機(jī)運(yùn)行狀態(tài)判斷規(guī)則，對各個(gè)廠家除重復(fù)數(shù)據(jù)的scada實(shí)時(shí)數(shù)據(jù)進(jìn)行運(yùn)行狀態(tài)解析，得到風(fēng)機(jī)運(yùn)行狀態(tài)數(shù)據(jù)，包括以下步驟，

（D1）通過復(fù)雜事件處理引擎esper的epl語句，解析風(fēng)機(jī)運(yùn)行狀態(tài)判斷規(guī)則，結(jié)合多個(gè)scada實(shí)時(shí)數(shù)據(jù)測點(diǎn)狀態(tài)位以及測點(diǎn)值，判斷風(fēng)機(jī)運(yùn)行狀態(tài)；

（D2）記錄風(fēng)機(jī)各運(yùn)行狀態(tài)的持續(xù)時(shí)間。

9.根據(jù)權(quán)利要求1所述的基于流計(jì)算的風(fēng)電機(jī)組scada數(shù)據(jù)的實(shí)時(shí)處理方法，其特征在于： 步驟（F），根據(jù)保存數(shù)據(jù)，對風(fēng)電機(jī)組的運(yùn)行狀態(tài)發(fā)生故障時(shí)，進(jìn)行診斷，包括以下步驟，

（F1）在保存數(shù)據(jù)內(nèi)檢測到故障代碼時(shí)，將故障代碼及發(fā)生故障時(shí)標(biāo)準(zhǔn)化后的風(fēng)機(jī)斷面數(shù)據(jù)，傳遞給風(fēng)機(jī)故障診斷算法；

（F2）利用風(fēng)機(jī)故障診斷算法分析故障代碼以及風(fēng)機(jī)斷面數(shù)據(jù)，給出風(fēng)機(jī)的故障原因；

（F3）將得到的風(fēng)機(jī)的故障原因，保存到關(guān)系數(shù)據(jù)庫mysql中，便于查詢。