Apache Storm整合OpenTSDB時序庫
隨著物聯網、智慧裝置等技術迅速發展和推廣應用,導致大量的時間序列資料需要整合和儲存。OpenTSDB 為時間序列資料提供了可擴充套件且高可用性的儲存。它由 Time Series Daemon (TSD) servers 以及命令列工具組成。每個 TSD 連線到配置的 HBase 叢集以 push/query(推送/查詢) 資料。
時間序列資料點包括:
(1)metric名稱描述
(2)UNIX時間戳(秒級或毫秒級)
(3)數值 (64位整數或單精度浮點數)
(4)系列tags (key-value鍵值對)
Storm Bolt 和 Trident State 從一個基於給定的 TupleMetricPointMapper 的 tuple 中建立了上面的時間序列資料。該模組提供了 Core Storm 和 Trident Bolt 實現,使用者將資料寫入 OpenTSDB。時間序列資料點被寫入時有 at-least-once(至少一次)的語義保證。