[發(fā)明專利]一種分布式時(shí)序數(shù)據(jù)庫、存儲(chǔ)方法、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011073550.8
• 申請(qǐng)日: 2020-10-09
• 公開（公告）號(hào): CN112199419A
• 公開（公告）日: 2021-01-08
• 發(fā)明（設(shè)計(jì)）人: 夏艦波
• 申請(qǐng)（專利權(quán)）人: 深圳市歡太科技有限公司;OPPO廣東移動(dòng)通信有限公司
• 主分類號(hào): G06F16/2458
• 分類號(hào): G06F16/2458;G06F16/27;G06F9/50
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理有限公司 11270
• 代理人: 姚璐;張穎玲

本申請(qǐng)實(shí)施例公開了一種分布式時(shí)序數(shù)據(jù)庫、存儲(chǔ)方法、設(shè)備及存儲(chǔ)介質(zhì)，所述分布式時(shí)序數(shù)據(jù)庫包括管理節(jié)點(diǎn)和若干個(gè)服務(wù)節(jié)點(diǎn)；其中，所述管理節(jié)點(diǎn)，用于管理所述若干個(gè)服務(wù)節(jié)點(diǎn)，并將待存儲(chǔ)的時(shí)序數(shù)據(jù)按照數(shù)據(jù)分片策略分配至對(duì)應(yīng)的服務(wù)節(jié)點(diǎn)；所述服務(wù)節(jié)點(diǎn)，用于接收所分配的時(shí)序數(shù)據(jù)并執(zhí)行相應(yīng)的服務(wù)操作。這樣，在該分布式時(shí)序數(shù)據(jù)庫中，基于若干個(gè)服務(wù)節(jié)點(diǎn)實(shí)現(xiàn)分布式架構(gòu)，而且還引入了管理節(jié)點(diǎn)，使得該分布式時(shí)序數(shù)據(jù)庫不僅可以具備服務(wù)高可用能力，而且還可以具備動(dòng)態(tài)可擴(kuò)展性和負(fù)載均衡能力，從而能夠滿足大吞吐量寫入查詢和大容量存儲(chǔ)的時(shí)序數(shù)據(jù)需求。

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

本申請(qǐng)涉及數(shù)據(jù)庫技術(shù)領(lǐng)域，尤其涉及一種分布式時(shí)序數(shù)據(jù)庫、存儲(chǔ)方法、設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

時(shí)序數(shù)據(jù)庫(Time Series Database，TSDB)又稱為時(shí)間序列數(shù)據(jù)庫，是一種集時(shí)序數(shù)據(jù)高效讀寫、壓縮存儲(chǔ)、實(shí)時(shí)計(jì)算能力為一體的數(shù)據(jù)庫服務(wù)，可廣泛應(yīng)用于物聯(lián)網(wǎng)和互聯(lián)網(wǎng)領(lǐng)域，實(shí)現(xiàn)對(duì)設(shè)備及業(yè)務(wù)服務(wù)的實(shí)時(shí)監(jiān)控，實(shí)時(shí)預(yù)測(cè)告警。

目前業(yè)界主流的開源TSDB，一部分TSDB不具有分布式方案，另一部分TSDB雖然基于分布式列存儲(chǔ)系統(tǒng)HBase、Cassandra等實(shí)現(xiàn)了分布式方案，但是目前的TSDB分布式方案存在明顯缺陷，例如，不具備服務(wù)高可用能力，任何服務(wù)節(jié)點(diǎn)掛掉或者網(wǎng)絡(luò)不通時(shí)，將會(huì)導(dǎo)致部分時(shí)序數(shù)據(jù)一直寫入失敗；另外，還不具備負(fù)載均衡能力，需要為所有服務(wù)節(jié)點(diǎn)配置前置的負(fù)載均衡設(shè)備；而且當(dāng)服務(wù)節(jié)點(diǎn)擴(kuò)展時(shí)，還需要手動(dòng)修改負(fù)載均衡的配置等。

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

本申請(qǐng)?zhí)岢鲆环N分布式時(shí)序數(shù)據(jù)庫、存儲(chǔ)方法、設(shè)備及存儲(chǔ)介質(zhì)，不僅可以具備服務(wù)高可用能力，而且還可以具備動(dòng)態(tài)可擴(kuò)展性和負(fù)載均衡能力，從而能夠滿足大吞吐量寫入查詢和大容量存儲(chǔ)的時(shí)序數(shù)據(jù)需求。

本申請(qǐng)的技術(shù)方案是這樣實(shí)現(xiàn)的：

第一方面，本申請(qǐng)實(shí)施例提供了一種分布式時(shí)序數(shù)據(jù)庫，所述分布式時(shí)序數(shù)據(jù)庫包括管理節(jié)點(diǎn)和若干個(gè)服務(wù)節(jié)點(diǎn)；其中，

所述管理節(jié)點(diǎn)，用于管理所述若干個(gè)服務(wù)節(jié)點(diǎn)，并將待存儲(chǔ)的時(shí)序數(shù)據(jù)按照數(shù)據(jù)分片策略分配至對(duì)應(yīng)的服務(wù)節(jié)點(diǎn)；

所述服務(wù)節(jié)點(diǎn)，用于接收所分配的時(shí)序數(shù)據(jù)并執(zhí)行相應(yīng)的服務(wù)操作。

第二方面，本申請(qǐng)實(shí)施例提供了一種基于分布式時(shí)序數(shù)據(jù)庫的存儲(chǔ)方法，所述分布式時(shí)序數(shù)據(jù)庫包括管理節(jié)點(diǎn)和若干個(gè)服務(wù)節(jié)點(diǎn)，該方法包括：

獲取待存儲(chǔ)的時(shí)序數(shù)據(jù)；

通過所述管理節(jié)點(diǎn)將所述待存儲(chǔ)的時(shí)序數(shù)據(jù)按照數(shù)據(jù)分片策略分配至對(duì)應(yīng)的服務(wù)節(jié)點(diǎn)；

通過所述服務(wù)節(jié)點(diǎn)接收所分配的時(shí)序數(shù)據(jù)并執(zhí)行相應(yīng)的服務(wù)操作。

第三方面，本申請(qǐng)實(shí)施例提供了一種基于分布式時(shí)序數(shù)據(jù)庫的存儲(chǔ)設(shè)備，該存儲(chǔ)設(shè)備包括存儲(chǔ)器和處理器；其中，

所述存儲(chǔ)器，用于存儲(chǔ)能夠在所述處理器上運(yùn)行的可執(zhí)行指令；

所述處理器，用于在運(yùn)行所述可執(zhí)行指令時(shí)，執(zhí)行如第二方面所述的方法。

第四方面，本申請(qǐng)實(shí)施例提供了一種計(jì)算機(jī)存儲(chǔ)介質(zhì)，該計(jì)算機(jī)存儲(chǔ)介質(zhì)存儲(chǔ)有基于分布式時(shí)序數(shù)據(jù)庫的存儲(chǔ)程序，所述基于分布式時(shí)序數(shù)據(jù)庫的存儲(chǔ)程序被至少一個(gè)處理器執(zhí)行時(shí)實(shí)現(xiàn)如第二方面所述的方法。