基于實(shí)時(shí)數(shù)倉(cāng)的實(shí)時(shí)流處理系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)

基本信息

申請(qǐng)?zhí)?/td> CN201910660197.4 申請(qǐng)日 -
公開（公告）號(hào) CN110362622B 公開（公告）日 2022-06-10
申請(qǐng)公布號(hào) CN110362622B 申請(qǐng)公布日 2022-06-10
分類號(hào) G06F16/25（2019.01）I;G06F16/2455（2019.01）I;G06F16/2458（2019.01）I;G06F16/23（2019.01）I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 張健宇 申請(qǐng)（專利權(quán)）人 江蘇滿運(yùn)軟件科技有限公司
代理機(jī)構(gòu) 上海隆天律師事務(wù)所 代理人 -
地址 210012江蘇省南京市雨花臺(tái)區(qū)軟件大道170-1號(hào)4幢3-5層
法律狀態(tài) -

摘要

摘要 本發(fā)明提供了基于實(shí)時(shí)數(shù)倉(cāng)的實(shí)時(shí)流處理系統(tǒng)、方法、設(shè)備及存儲(chǔ)介質(zhì)，該系統(tǒng)中，實(shí)時(shí)環(huán)境模塊中的第一實(shí)時(shí)處理單元定時(shí)自檢獲得第一檢測(cè)信息，實(shí)時(shí)數(shù)據(jù)庫(kù)中的檢測(cè)單元用于獲得關(guān)于所述實(shí)時(shí)數(shù)據(jù)庫(kù)的第二檢測(cè)信息，離線環(huán)境模塊中的第二實(shí)時(shí)處理單元定時(shí)自檢獲得第三檢測(cè)信息，批處理單元定時(shí)自檢獲得第四檢測(cè)信息；控制模塊根據(jù)第一檢測(cè)信息、第二檢測(cè)信息、第三檢測(cè)信息以及第四檢測(cè)信息的狀態(tài)，自第一實(shí)時(shí)處理單元、第二實(shí)時(shí)處理單元以及批處理單元中選一啟動(dòng)，獲得輸出數(shù)據(jù)并寫入到被寫入對(duì)象，并自實(shí)時(shí)數(shù)據(jù)庫(kù)和離線數(shù)據(jù)庫(kù)中擇一作為被寫入對(duì)象。本發(fā)明能夠自動(dòng)升降級(jí)提高實(shí)時(shí)數(shù)倉(cāng)可用性，提高下游業(yè)務(wù)方友好度，保持總控程序高度可用。