[發(fā)明專利]時序數(shù)據(jù)管理方法、系統(tǒng)、計(jì)算設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011387807.7
• 申請日: 2020-12-01
• 公開（公告）號: CN112541038A
• 公開（公告）日: 2021-03-23
• 發(fā)明（設(shè)計(jì)）人: 張建興;李林森;金兵兵;姜鴻康;王凱慶
• 申請（專利權(quán)）人: 杭州海康威視數(shù)字技術(shù)股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/2458;G06F9/50
• 代理公司: 北京德琦知識產(chǎn)權(quán)代理有限公司 11018
• 代理人: 程杰;王琦

1.一種時序數(shù)據(jù)管理方法，其特征在于，包括：

響應(yīng)于對時序數(shù)據(jù)的非互斥任務(wù)，由負(fù)載均衡設(shè)備從計(jì)算資源池中選定用于處理所述非互斥任務(wù)的計(jì)算節(jié)點(diǎn)，所述計(jì)算資源池包括多個計(jì)算節(jié)點(diǎn)，所述非互斥任務(wù)表示所述計(jì)算資源池中計(jì)算節(jié)點(diǎn)均可以執(zhí)行的任務(wù)；

將所述非互斥任務(wù)發(fā)送到選定的計(jì)算節(jié)點(diǎn)；

由選定的計(jì)算節(jié)點(diǎn)向時序數(shù)據(jù)存儲系統(tǒng)發(fā)送與所述非互斥任務(wù)對應(yīng)的數(shù)據(jù)獲取請求；

響應(yīng)于所述數(shù)據(jù)獲取請求，由所述時序數(shù)據(jù)存儲系統(tǒng)向所述選定的計(jì)算節(jié)點(diǎn)返回查詢到的時序數(shù)據(jù)；

由所述選定的計(jì)算節(jié)點(diǎn)，對所述查詢到的時序數(shù)據(jù)進(jìn)行業(yè)務(wù)處理。

2.如權(quán)利要求1所述的時序數(shù)據(jù)管理方法，其特征在于，進(jìn)一步包括：

對于所述計(jì)算資源池中任一個計(jì)算節(jié)點(diǎn)，由該計(jì)算節(jié)點(diǎn)向所述時序數(shù)據(jù)存儲系統(tǒng)發(fā)送主節(jié)點(diǎn)注冊請求；

響應(yīng)于所述主節(jié)點(diǎn)注冊請求，由時序數(shù)據(jù)存儲系統(tǒng)判斷所述計(jì)算資源池是否已存在主節(jié)點(diǎn)，所述主節(jié)點(diǎn)用于執(zhí)行互斥型任務(wù)，所述互斥型任務(wù)表示適合由所述計(jì)算資源池中單一計(jì)算節(jié)點(diǎn)執(zhí)行的任務(wù)；

在確定所述計(jì)算資源池已存在主節(jié)點(diǎn)時，由時序數(shù)據(jù)存儲系統(tǒng)將該計(jì)算節(jié)點(diǎn)注冊為從節(jié)點(diǎn)；

在確定所述計(jì)算資源池不存在主節(jié)點(diǎn)時，由時序數(shù)據(jù)存儲系統(tǒng)將該計(jì)算節(jié)點(diǎn)注冊為主節(jié)點(diǎn)；

對于所述計(jì)算資源池中任一個計(jì)算節(jié)點(diǎn)，由該計(jì)算節(jié)點(diǎn)判斷自身是否為主節(jié)點(diǎn)；

在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，執(zhí)行所述互斥型任務(wù)。

3.如權(quán)利要求2所述的時序數(shù)據(jù)管理方法，其特征在于，所述非互斥型任務(wù)為定時任務(wù)；所述在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，執(zhí)行所述互斥型任務(wù)，包括：

在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，由該計(jì)算節(jié)點(diǎn)啟動計(jì)時操作，并在計(jì)時時長到達(dá)所述定時任務(wù)的預(yù)定時長時，執(zhí)行所述互斥型任務(wù)，并存儲相應(yīng)的任務(wù)處理結(jié)果。

4.如權(quán)利要求1所述的時序數(shù)據(jù)管理方法，其特征在于，所述由選定的計(jì)算節(jié)點(diǎn)向時序數(shù)據(jù)存儲系統(tǒng)發(fā)送與所述非互斥任務(wù)對應(yīng)的數(shù)據(jù)獲取請求，包括：由選定的計(jì)算節(jié)點(diǎn)生成數(shù)據(jù)庫查詢計(jì)劃；向所述時序數(shù)據(jù)存儲系統(tǒng)發(fā)送包含所述數(shù)據(jù)查詢計(jì)劃的數(shù)據(jù)獲取請求。

5.一種時序數(shù)據(jù)管理系統(tǒng)，其特征在于，包括：

計(jì)算資源池，包括多個計(jì)算節(jié)點(diǎn)；

時序數(shù)據(jù)存儲系統(tǒng)，存儲有時序數(shù)據(jù)；

負(fù)載均衡設(shè)備，響應(yīng)于對時序數(shù)據(jù)的非互斥任務(wù)，從計(jì)算資源池中選定用于處理所述非互斥任務(wù)的計(jì)算節(jié)點(diǎn)，并將所述非互斥任務(wù)發(fā)送到選定的計(jì)算節(jié)點(diǎn)，所述非互斥任務(wù)表示所述計(jì)算資源池中計(jì)算節(jié)點(diǎn)均可以執(zhí)行的任務(wù)；

其中，選定的計(jì)算節(jié)點(diǎn)，向時序數(shù)據(jù)存儲系統(tǒng)發(fā)送與所述非互斥任務(wù)對應(yīng)的數(shù)據(jù)獲取請求；所述時序數(shù)據(jù)存儲系統(tǒng)響應(yīng)于所述數(shù)據(jù)獲取請求，向所述選定的計(jì)算節(jié)點(diǎn)返回查詢到的時序數(shù)據(jù)；所述選定的計(jì)算節(jié)點(diǎn)，對所述查詢到的時序數(shù)據(jù)進(jìn)行業(yè)務(wù)處理。

6.如權(quán)利要求5所述的時序數(shù)據(jù)管理系統(tǒng)，其特征在于，

對于所述計(jì)算資源池中任一個計(jì)算節(jié)點(diǎn)，該計(jì)算節(jié)點(diǎn)向所述時序數(shù)據(jù)存儲系統(tǒng)發(fā)送主節(jié)點(diǎn)注冊請求；

響應(yīng)于所述主節(jié)點(diǎn)注冊請求，時序數(shù)據(jù)存儲系統(tǒng)判斷所述計(jì)算資源池是否已存在主節(jié)點(diǎn)，所述主節(jié)點(diǎn)用于執(zhí)行互斥型任務(wù)，所述互斥型任務(wù)表示適合由所述計(jì)算資源池中單一計(jì)算節(jié)點(diǎn)執(zhí)行的任務(wù)；

在確定所述計(jì)算資源池已存在主節(jié)點(diǎn)時，時序數(shù)據(jù)存儲系統(tǒng)將該計(jì)算節(jié)點(diǎn)注冊為從節(jié)點(diǎn)；

在確定所述計(jì)算資源池不存在主節(jié)點(diǎn)時，時序數(shù)據(jù)存儲系統(tǒng)將該計(jì)算節(jié)點(diǎn)注冊為主節(jié)點(diǎn)；

對于所述計(jì)算資源池中任一個計(jì)算節(jié)點(diǎn)，由該計(jì)算節(jié)點(diǎn)判斷自身是否為主節(jié)點(diǎn)；

在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，執(zhí)行所述互斥型任務(wù)。

7.如權(quán)利要求6所述的時序數(shù)據(jù)管理系統(tǒng)，其特征在于，所述非互斥型任務(wù)為定時任務(wù)；所述在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，執(zhí)行所述互斥型任務(wù)，包括：

在該計(jì)算節(jié)點(diǎn)為主節(jié)點(diǎn)時，由該計(jì)算節(jié)點(diǎn)啟動計(jì)時操作，并在計(jì)時時長到達(dá)所述定時任務(wù)的預(yù)定時長時，執(zhí)行所述互斥型任務(wù)，并存儲相應(yīng)的任務(wù)處理結(jié)果。