[發明專利]一種基于定時任務調度的設備實時監測系統

在審

• 申請號: 201611257835.0
• 申請日: 2016-12-30
• 公開（公告）號: CN106780149A
• 公開（公告）日: 2017-05-31
• 發明（設計）人: 王苗苗;王欣;楊鴻翔;劉恒;李建春;劉小年;曹雪明;吳舜華;孫永信;王巖;鮑旭東;傅劍;王群;李云;胡宇杰
• 申請（專利權）人: 中核核電運行管理有限公司
• 主分類號: G06Q50/06
• 分類號: G06Q50/06
• 代理公司: 核工業專利中心11007
• 代理人: 程然

技術領域

本發明屬于核電站設備可靠性系統定時調度任務技術領域，具體涉及一種基于定時任務調度的設備實時監測系統。

背景技術

在電廠的監測數據展示方面，由于需要處理的是實時的數據流，并且有時數據量比較大。需要實時展示設備參數的狀態，而參數狀態的判斷以及渲染處理需要消耗大量的系統資源，導致頁面在展示的時候經常卡頓，導致用戶體驗不佳。

如果使用調度服務在后臺處理數據，將參數的狀態以及相關的運算，在后臺進行預處理，直接在前臺展示結果，會提高頁面的展示速度。但是，在集團級層面上，將會涉及多個電站的計算機系統。在多個計算機系統中，不同軟件供應商的產品差異巨大，導致數據的匯集處理復雜。需要使用多個調度程序，分別處理匯總、統一到一個地方，然后再進行處理。整個處理過程環節比較多，處理復雜，數據結果延時較長，不適用于實時性要求比較高的數據處理。

發明內容

本發明目的在于提出一種基于定時任務調度的設備實時監測系統，可以實現多個多源數據訪問、定時處理任務和處理過程定制化，建立多臺服務器集群化運行。

本發明是這樣實現的：

一種基于定時任務調度的設備實時監測系統，包括定時任務調度引擎、業務邏輯處理器和數據采集器；數據采集器將不同的數據源上的實時數據采集過來，將采集過來的數據進行數據清洗和格式轉換，最終轉化成可以處理的格式統一的數據，將處理好的數據傳遞給業務邏輯處理器；業務邏輯處理器接收到數據之后，根據配置的或者固化到代碼中的業務邏輯處理這些數據；數據處理完成之后，再將數據發送給數據采集器，由數據采集器將這些數據寫入到指定的數據庫中。

如上所述的定時任務調度引擎采用terracotta的quartz來處理定時任務的調度。

如上所述的數據采集器為專門和數據庫交互的組件，用于將從不同數據庫中讀取的數據歸集到一起，然后進行數據清洗。

如上所述的數據清洗的步驟為：

步驟1：將不同類型的數據轉換成相同類型的數據；

步驟2：篩選需要的數據；

步驟3：數據去重。

如上所述的數據采集器還用于將處理完成的數據歸集到一起，然后寫入到數據庫中。

如上所述的業務邏輯處理器用于處理業務邏輯。

如上所述的業務邏輯是固化到代碼中的，或使用簡單的代碼表述業務邏輯處理過程。

本發明的有益效果是：

本發明可以降低后臺處理程序的復雜程度，減輕運維工作量。同時，提高頁面的展示速度，提升數據處理的能力。具體如下：

1.便于集團化大型項目的數據處理，支持多數據源、海量實時數據處理。特別是多個數據源格式不一致，可以是存儲方式不一致也可以是數據格式本身就不一致。

2.提升預處理的能力，降低頁面操作后臺處理的復雜程度，提升頁面的展示效率，以助于提升用戶體驗。

3.集群化使得多進程與多線程同時生效，充分利用多核心多計算機的計算能力，使得后臺計算量更大，計算速度更快。

附圖說明

圖1是本發明的一種基于定時任務調度的設備實時監測系統的結構原理圖；

圖2是本發明的一種基于定時任務調度的設備實時監測系統的定時任務調度引擎配置后的系統架構圖。

具體實施方式

下面結合附圖和實施例對本發明進行進一步描述。

本發明使用的基于調度任務的設備實時狀態檢測系統可以分成三個部分，包括：1.定時任務調度引擎采用quartz-scheduler實現；2.業務邏輯處理器——處理特殊的業務邏輯；3.數據采集器——數據采集、清洗以及持久化。各個部分的邏輯組成關系是，首先需要使用數據采集器，將不同的數據源上的實時數據采集過來，然后，將采集過來的數據進行數據清洗，格式轉換，最終轉化成可以處理的格式統一的數據，將處理好的數據傳遞給下一個環節業務邏輯處理器。業務邏輯處理器拿到數據之后，根據配置的(或者固化到代碼中的)業務邏輯處理這些數據。數據處理完成之后，再將數據交給數據采集器，由數據采集器將這些數據寫入到指定的數據庫中去，如圖1所示。

定時任務調度引擎：