數(shù)據(jù)訂閱是一種數(shù)據(jù)查詢方式，其特點(diǎn)為：客戶端執(zhí)行一個(gè)查詢語(yǔ)句后，可以增量形式，不斷收到新到達(dá)服務(wù)端的、符合查詢條件的數(shù)據(jù)。相比普通查詢，訂閱能夠持續(xù)地、低延遲地將新寫(xiě)入的數(shù)據(jù)返回客戶端。

什么時(shí)候需要數(shù)據(jù)訂閱？

訂閱是一種低成本地、實(shí)時(shí)獲取 TDengine 時(shí)序數(shù)據(jù)庫(kù)(Time Series DataBase)最新數(shù)據(jù)的方法?？蛻舳顺绦蚺c數(shù)據(jù)庫(kù)的交互，通常是由客戶端發(fā)起查詢，再由數(shù)據(jù)庫(kù)返回?cái)?shù)據(jù)。假設(shè)每當(dāng)數(shù)據(jù)庫(kù)有數(shù)據(jù)寫(xiě)入時(shí)，都需要立即將新的寫(xiě)入結(jié)果發(fā)送給某客戶端，如果用查詢的方式實(shí)現(xiàn)，則需要由客戶端定時(shí)發(fā)起輪詢。而大量的發(fā)起查詢，會(huì)增加客戶端與服務(wù)器的資源消耗；且根據(jù)輪詢的頻率，獲取最新數(shù)據(jù)會(huì)有一定的延遲。我們可以將訂閱看作是持續(xù)不斷的長(zhǎng)查詢，一旦數(shù)據(jù)更新（包括新插入），則會(huì)立即被推送至客戶端，當(dāng)數(shù)據(jù)沒(méi)有更新時(shí)，不會(huì)有額外的資源消耗。

TDengine 時(shí)序數(shù)據(jù)庫(kù)的訂閱可以在服務(wù)端過(guò)濾數(shù)據(jù)，從而降低了資源消耗，并且簡(jiǎn)化了應(yīng)用層實(shí)現(xiàn)。

很多分布式實(shí)時(shí)數(shù)據(jù)庫(kù)需要集成消息隊(duì)列產(chǎn)品來(lái)實(shí)現(xiàn)數(shù)據(jù)訂閱功能。而 TDengine 提供了類似消息隊(duì)列產(chǎn)品的數(shù)據(jù)訂閱、消費(fèi)接口，用戶無(wú)需再集成其他產(chǎn)品，從而簡(jiǎn)化系統(tǒng)設(shè)計(jì)的復(fù)雜度，降低運(yùn)維成本。

那么，TDengine 時(shí)序數(shù)據(jù)庫(kù)（TSDB） 是如何實(shí)現(xiàn)訂閱功能的？如何通過(guò)訂閱功能獲取數(shù)據(jù)？

TDengine 研發(fā)工程師劉繼聰為大家分享《分布式數(shù)據(jù)庫(kù)訂閱功能的原理及實(shí)現(xiàn)》。

內(nèi)容大綱：

• 訂閱功能及其基本使用
• 分布式訂閱、消費(fèi)者與消費(fèi)者組
• 通過(guò)訂閱獲取 TSDB 數(shù)據(jù)以及 WAL 數(shù)據(jù)
• 通過(guò)訂閱進(jìn)行 DB 的實(shí)時(shí)備份