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（至少一次）的语义保证。