TDengine 是一款開源、高性能、云原生的時序數(shù)據(jù)庫(Time Series Database, TSDB),它專為物聯(lián)網(wǎng)、車聯(lián)網(wǎng)、工業(yè)互聯(lián)網(wǎng)、金融、IT 運維等場景優(yōu)化設計。同時它還帶有內建的緩存、流式計算、時序數(shù)據(jù)訂閱等系統(tǒng)功能,能大幅減少系統(tǒng)設計的復雜度,降低研發(fā)和運營成本,是一款極簡的時序數(shù)據(jù)處理平臺。
為了幫助應用實時獲取寫入 TDengine 的數(shù)據(jù),或者以事件到達順序處理數(shù)據(jù),TDengine 提供了類似消息隊列產品的數(shù)據(jù)訂閱、消費接口。這樣在很多場景下,采用 TDengine 的時序數(shù)據(jù)處理系統(tǒng)不再需要集成消息隊列產品,比如 kafka,從而簡化系統(tǒng)設計的復雜度,降低運營維護成本。
與其他消息隊列軟件相比,這是 TDengine 數(shù)據(jù)訂閱功能的最大的優(yōu)勢,它提供了更大的靈活性,數(shù)據(jù)的顆粒度可以由應用隨時調整,而且數(shù)據(jù)的過濾與預處理交給 TDengine,而不是應用完成,有效的減少傳輸?shù)臄?shù)據(jù)量與應用的復雜度。
TDengine 訂閱功能支持多種訂閱類型:
- 列訂閱
- 超級表訂閱
- 數(shù)據(jù)庫訂閱
使用數(shù)據(jù)訂閱功能非常簡單,大致流程如下:
- 寫入數(shù)據(jù)
- 創(chuàng)建 topic
- 創(chuàng)建消費者 consumer
- 訂閱 topic
- 消費
- 結束消費
- 刪除 topic
在訂閱過程中,可以通過 SQL 語句查看狀態(tài)。
具體的操作方法和示例代碼,請參考 TDengine 文檔中的 數(shù)據(jù)訂閱 一章。
總之,TDengine 的數(shù)據(jù)訂閱功能是一種高效、靈活、可靠的實時數(shù)據(jù)獲取方式,它可以為用戶提供更多的可能性和價值。如果你對 TDengine 的其他功能感興趣,請繼續(xù)瀏覽 TDengine 文檔。



互聯(lián)網(wǎng).png)



-1.png)












伙伴.png)



