[發(fā)明專利]基于Web的大型工業(yè)系統(tǒng)反饋數(shù)據(jù)實(shí)時(shí)處理方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201410228031.2
• 申請(qǐng)日: 2014-05-27
• 公開（公告）號(hào): CN103970903B
• 公開（公告）日: 2017-05-24
• 發(fā)明（設(shè)計(jì)）人: 張可;柴毅;汪嘉文;江聰美;焦春曉
• 申請(qǐng)（專利權(quán)）人: 重慶大學(xué)
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 北京眾合誠(chéng)成知識(shí)產(chǎn)權(quán)代理有限公司11246
• 代理人: 龔燮英

1.基于Web的大型工業(yè)系統(tǒng)反饋數(shù)據(jù)實(shí)時(shí)處理方法，其特征在于：包括以下步驟：

S1：建立用于采集工業(yè)現(xiàn)場(chǎng)設(shè)備的工業(yè)系統(tǒng)原始數(shù)據(jù)的底層數(shù)據(jù)層；

S2：建立用于將底層數(shù)據(jù)層中所采集的工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行分布數(shù)據(jù)處理的數(shù)據(jù)處理層，同時(shí)建立用于實(shí)時(shí)數(shù)據(jù)訪問與歷史數(shù)據(jù)檢索優(yōu)化的時(shí)間戳；

S3：建立對(duì)工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行動(dòng)態(tài)分頁存儲(chǔ)的數(shù)據(jù)分發(fā)層，在數(shù)據(jù)分發(fā)層建立同步更新模塊與檢索服務(wù)模塊；

所述數(shù)據(jù)處理層的建立包括以下步驟：

S21：建立預(yù)處理模塊，所述預(yù)處理模塊用于對(duì)采集到的工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行拆分、數(shù)據(jù)合法性驗(yàn)證、不同數(shù)據(jù)邏輯關(guān)聯(lián)提取和數(shù)據(jù)格式轉(zhuǎn)換；

S22：建立引擎模塊，所述引擎模塊用于調(diào)度處理線程、分配線程與模塊控制管理；

S23：建立分庫存儲(chǔ)模塊，所述分庫存儲(chǔ)的方式采用分布式內(nèi)存數(shù)據(jù)庫系統(tǒng)和分布式磁盤數(shù)據(jù)庫；

所述分布式內(nèi)存數(shù)據(jù)庫系統(tǒng)用于實(shí)現(xiàn)實(shí)時(shí)數(shù)據(jù)訪問；

所述分布式磁盤數(shù)據(jù)庫包括同步更新模塊和檢索服務(wù)模塊；

所述同步更新模塊，用于斷電時(shí)通過實(shí)時(shí)表來保存內(nèi)存數(shù)據(jù)庫中的實(shí)時(shí)數(shù)據(jù)；

所述檢索服務(wù)模塊，用于保存歷史記錄數(shù)據(jù)；

所述數(shù)據(jù)分發(fā)層的建立包括建立同步更新模塊與建立檢索服務(wù)模塊；

所述同步更新模塊，按照數(shù)據(jù)處理層中建立的分布式內(nèi)存數(shù)據(jù)庫的配置信息，在磁盤數(shù)據(jù)庫中給每個(gè)參數(shù)同步建立一條實(shí)時(shí)更新的記錄；根據(jù)引擎模塊中的處理標(biāo)志位來識(shí)別原數(shù)據(jù)源是否被處理過；

所述檢索服務(wù)模塊，實(shí)時(shí)更新記錄來判斷經(jīng)過數(shù)據(jù)預(yù)處理層處理后的表征設(shè)備實(shí)時(shí)狀態(tài)的數(shù)據(jù)是否發(fā)生變化，如果數(shù)據(jù)發(fā)生變化則存入歷史數(shù)據(jù)表，所述歷史數(shù)據(jù)表存儲(chǔ)于分布式磁盤數(shù)據(jù)庫，歷史數(shù)據(jù)表的分類根據(jù)數(shù)據(jù)處理層中提取出的映射關(guān)系信息進(jìn)行分類，當(dāng)記錄數(shù)達(dá)到預(yù)設(shè)條數(shù)時(shí)同步建立第二張數(shù)據(jù)表，在數(shù)據(jù)達(dá)到預(yù)設(shè)規(guī)模時(shí)對(duì)歷史數(shù)據(jù)表進(jìn)行備份清空。

2.根據(jù)權(quán)利要求1所述的基于Web的大型工業(yè)系統(tǒng)反饋數(shù)據(jù)實(shí)時(shí)處理方法，其特征在于：所述底層數(shù)據(jù)層的工業(yè)系統(tǒng)原始數(shù)據(jù)是指工業(yè)現(xiàn)場(chǎng)的所有設(shè)備的運(yùn)行狀態(tài)參數(shù)與實(shí)時(shí)參數(shù)值，所述工業(yè)現(xiàn)場(chǎng)設(shè)備包括傳感器設(shè)備、供電子系統(tǒng)、消防子系統(tǒng)和電梯子系統(tǒng)。

3.根據(jù)權(quán)利要求2所述的基于Web的大型工業(yè)系統(tǒng)反饋數(shù)據(jù)實(shí)時(shí)處理方法，其特征在于：所述分布式磁盤數(shù)據(jù)庫為外部數(shù)據(jù)庫服務(wù)器；所述同步更新模塊與檢索服務(wù)模塊的所有操作均設(shè)置在磁盤數(shù)據(jù)庫中進(jìn)行。

4.基于Web的大型工業(yè)系統(tǒng)反饋數(shù)據(jù)實(shí)時(shí)處理系統(tǒng)，其特征在于：包括底層數(shù)據(jù)層、數(shù)據(jù)處理層和數(shù)據(jù)分發(fā)層；

所述底層數(shù)據(jù)層，用于采集工業(yè)現(xiàn)場(chǎng)設(shè)備的工業(yè)系統(tǒng)原始數(shù)據(jù)的；

所述數(shù)據(jù)處理層，用于將底層數(shù)據(jù)層中所采集的工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行分布數(shù)據(jù)處理，同時(shí)建立用于實(shí)時(shí)數(shù)據(jù)訪問與歷史數(shù)據(jù)檢索優(yōu)化的時(shí)間戳；

所述數(shù)據(jù)分發(fā)層，用于對(duì)工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行動(dòng)態(tài)分頁存儲(chǔ)；

所述數(shù)據(jù)處理層包括預(yù)處理模塊、引擎模塊、分庫存儲(chǔ)模塊；

所述預(yù)處理模塊，所述預(yù)處理模塊用于對(duì)采集到的工業(yè)系統(tǒng)原始數(shù)據(jù)進(jìn)行拆分、數(shù)據(jù)合法性驗(yàn)證、不同數(shù)據(jù)邏輯關(guān)聯(lián)提取、數(shù)據(jù)格式轉(zhuǎn)換；

所述引擎模塊，所述引擎模塊用于調(diào)度處理線程、分配線程與模塊控制管理；

所述分庫存儲(chǔ)模塊，所述分庫存儲(chǔ)的方式采用分布式內(nèi)存數(shù)據(jù)庫系統(tǒng)和分布式磁盤數(shù)據(jù)庫；

所述分布式內(nèi)存數(shù)據(jù)庫系統(tǒng)用于實(shí)現(xiàn)實(shí)時(shí)數(shù)據(jù)訪問；

所述分布式磁盤數(shù)據(jù)庫包括同步更新模塊和檢索服務(wù)模塊；

所述同步更新模塊，用于斷電時(shí)通過實(shí)時(shí)表來保存內(nèi)存數(shù)據(jù)庫中的實(shí)時(shí)數(shù)據(jù)；

所述檢索服務(wù)模塊，用于保存歷史記錄數(shù)據(jù)；

所述數(shù)據(jù)分發(fā)層包括同步更新模塊與檢索服務(wù)模塊；

所述同步更新模塊，按照數(shù)據(jù)處理層中建立的分布式內(nèi)存數(shù)據(jù)庫的配置信息，在磁盤數(shù)據(jù)庫中給每個(gè)參數(shù)同步建立一條實(shí)時(shí)更新的記錄；根據(jù)引擎模塊中的處理標(biāo)志位來識(shí)別原數(shù)據(jù)源是否被處理過；

所述檢索服務(wù)模塊，實(shí)時(shí)更新記錄來判斷數(shù)據(jù)是否發(fā)生變化，如若變化則存入歷史數(shù)據(jù)表，所述歷史數(shù)據(jù)表存儲(chǔ)于分布式磁盤數(shù)據(jù)庫，歷史數(shù)據(jù)表的分類根據(jù)數(shù)據(jù)處理層中提取出的映射關(guān)系信息進(jìn)行分類，當(dāng)記錄數(shù)達(dá)到預(yù)設(shè)條數(shù)時(shí)同步建立第二張數(shù)據(jù)表，在數(shù)據(jù)達(dá)到預(yù)設(shè)規(guī)模時(shí)對(duì)歷史數(shù)據(jù)表進(jìn)行備份清空；

所述映射關(guān)系信息為分布在不同子系統(tǒng)中的設(shè)備信息采集單元讀取的設(shè)備實(shí)時(shí)運(yùn)行狀態(tài)數(shù)據(jù)。