[發(fā)明專利]一種基于分布式的管網(wǎng)產(chǎn)銷差計(jì)算調(diào)整方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201811244186.X
• 申請(qǐng)日: 2018-10-24
• 公開(kāi)（公告）號(hào): CN109360025A
• 公開(kāi)（公告）日: 2019-02-19
• 發(fā)明（設(shè)計(jì)）人: 趙偉;吳劍清;萬(wàn)新楚
• 申請(qǐng)（專利權(quán)）人: 云賽智聯(lián)股份有限公司
• 主分類號(hào): G06Q30/02
• 分類號(hào): G06Q30/02;G06Q50/06
• 代理公司: 昆明合眾智信知識(shí)產(chǎn)權(quán)事務(wù)所 53113
• 代理人: 張璽

本發(fā)明公開(kāi)了一種基于分布式的管網(wǎng)產(chǎn)銷差計(jì)算調(diào)整方法，步驟為：1、CSC啟動(dòng)并向CMP注冊(cè)；2、CMP啟動(dòng)供水量、售水量CSC并行計(jì)算；3、等待直至供水量和售水量計(jì)算完畢；4、啟動(dòng)產(chǎn)銷差CSC；5、判斷是否有未計(jì)算數(shù)據(jù)，如果否則結(jié)束，如果是則繼續(xù)；6、判斷隊(duì)列中是否有數(shù)據(jù)，如果沒(méi)有數(shù)據(jù)則關(guān)閉CSC，直至所有CSC執(zhí)行完畢；7、創(chuàng)建啟動(dòng)NODE并獲取未計(jì)算的數(shù)據(jù)，然后計(jì)算產(chǎn)銷差；8、判斷是否有未計(jì)算數(shù)據(jù)，如果有則返回重新獲取數(shù)據(jù)；如果否則結(jié)束NODE；9、判斷得到的產(chǎn)銷差是否大于20％，如果是則該區(qū)域管網(wǎng)系統(tǒng)漏損嚴(yán)重需要排查，如果否則該區(qū)域管網(wǎng)系統(tǒng)安全。本發(fā)明以容器為計(jì)算節(jié)點(diǎn)，容器之間計(jì)算互相隔離、環(huán)境穩(wěn)定，容錯(cuò)率高，而且支持流程編排。

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

本發(fā)明屬于供水行業(yè)技術(shù)領(lǐng)域，特別涉及一種基于分布式的管網(wǎng)產(chǎn)銷差計(jì)算調(diào)整方法。

背景技術(shù)

在供水行業(yè)中，產(chǎn)銷差的大小變化直接影響供水企業(yè)的經(jīng)濟(jì)效益，而計(jì)算產(chǎn)銷差離不開(kāi)各種儀器儀表上傳的時(shí)間序列數(shù)據(jù)。以單位用戶為例，需要記錄正累計(jì)水量、反累計(jì)水量、總累計(jì)水量、瞬時(shí)流量、壓力等數(shù)據(jù)，每5分鐘上傳一條，以一座中等城市10000個(gè)單位用戶為例，一天就是5*288*10000＝14400000條數(shù)據(jù)，而計(jì)算產(chǎn)銷差還需要流量?jī)x和居民等數(shù)據(jù)這又是一個(gè)龐大的數(shù)據(jù)集。除此之外我們還需要對(duì)這些數(shù)據(jù)進(jìn)行預(yù)處理之后才能使用，這就需要我們有一定的流程編排，順序性也亟待解決。

傳統(tǒng)的分布式計(jì)算，例如Hadoop MapReduce使用了大批量的任務(wù)集群，正式由于批量執(zhí)行，時(shí)效性比較低，而且我們不能對(duì)計(jì)算的內(nèi)容進(jìn)行編排，沒(méi)有與容器技術(shù)更好的融合，不能解決行業(yè)問(wèn)題。

單節(jié)點(diǎn)計(jì)算可以控制計(jì)算步驟，編排計(jì)算流程，但是面對(duì)供水行業(yè)如此龐大的數(shù)據(jù)集的時(shí)候往往力不從心，不僅僅失去了時(shí)效性，更不得不占用白天時(shí)間進(jìn)行計(jì)算，嚴(yán)重影響正常生產(chǎn)運(yùn)行。而傳統(tǒng)的分布式計(jì)算，以機(jī)器為節(jié)點(diǎn)，雖然計(jì)算速度很快，但是機(jī)器配置不一，無(wú)法充分利用資源，并且數(shù)據(jù)流程不可控，開(kāi)發(fā)人員不得不花大量精力去關(guān)注流程問(wèn)題，考慮先后順序，誤碼率高、程序耦合性強(qiáng)。

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

發(fā)明目的：為了克服現(xiàn)有技術(shù)中存在的計(jì)算產(chǎn)銷差速度慢、周期長(zhǎng)、時(shí)效性差、容錯(cuò)率低等不足，本發(fā)明提供一種集群是以容器為計(jì)算節(jié)點(diǎn)，容器之間計(jì)算互相隔離、環(huán)境穩(wěn)定，容錯(cuò)率高，而且支持流程編排的基于分布式的管網(wǎng)產(chǎn)銷差計(jì)算調(diào)整方法。

技術(shù)方案：為實(shí)現(xiàn)上述目的，本發(fā)明提供一種基于分布式的管網(wǎng)產(chǎn)銷差計(jì)算調(diào)整方法，包括如下步驟：

(1)供水量、售水量、產(chǎn)銷差CSC啟動(dòng)并向CMP注冊(cè)，提交產(chǎn)銷差計(jì)算的先決條件；

(2)CMP啟動(dòng)不需要先決條件的供水量、售水量CSC并行計(jì)算；

(3)判斷供水量和售水量是否計(jì)算完畢，如果計(jì)算完畢則進(jìn)入步驟(4)，如果沒(méi)有計(jì)算完畢則繼續(xù)等待直至計(jì)算完畢并進(jìn)入步驟(4)；

(4)啟動(dòng)產(chǎn)銷差CSC；將所需要計(jì)算的DMA、站點(diǎn)，按DMA、站點(diǎn)個(gè)數(shù)進(jìn)行分組，并把DMA、站點(diǎn)分組數(shù)據(jù)放入待計(jì)算的隊(duì)列；

(5)判斷是否有未計(jì)算數(shù)據(jù)，如果否則進(jìn)入步驟(9)，如果是則等待并進(jìn)入步驟(6)；

(6)判斷隊(duì)列中是否有數(shù)據(jù)，如果有數(shù)據(jù)則進(jìn)入步驟(7)，如果沒(méi)有數(shù)據(jù)則進(jìn)入步驟(9)；

(7)創(chuàng)建啟動(dòng)NODE并獲取未計(jì)算的數(shù)據(jù)，然后計(jì)算產(chǎn)銷差；

(8)判斷是否有未計(jì)算數(shù)據(jù)，如果有則返回步驟(7)重新獲取數(shù)據(jù)；如果否則結(jié)束NODE；

(9)關(guān)閉CSC，直至所有CSC執(zhí)行完畢；

(10)判斷步驟(7)中，計(jì)算得到的產(chǎn)銷差是否大于20％，如果是則該區(qū)域管網(wǎng)系統(tǒng)漏損嚴(yán)重需要排查，如果否則該區(qū)域管網(wǎng)系統(tǒng)安全。