MQTT 和 OpenTSDB 集成

输入和输出集成概述

MQTT Telegraf 插件旨在从指定的 MQTT 主题读取数据并创建指标，使用户能够利用 MQTT 进行实时数据收集和监控。

OpenTSDB 插件有助于 Telegraf 与 OpenTSDB 的集成，允许用户将时间序列指标无缝推送到 OpenTSDB 后端。

集成详细信息

MQTT

MQTT 插件允许从指定的 MQTT 主题读取指标，并使用支持的输入数据格式创建指标。 此插件作为服务输入运行，它侦听传入的指标或事件，而不是像普通插件那样按设定的时间间隔收集它们。 该插件的灵活性通过支持各种代理 URL、主题和连接功能（包括服务质量 (QoS) 级别和持久会话）得到增强。 其配置选项包含用于修改指标和有效处理启动错误的全局设置。 它还支持用于保护用户名和密码选项的密钥存储配置，确保与 MQTT 服务器的安全连接。

OpenTSDB

OpenTSDB 插件旨在通过 telnet 或 HTTP 模式将指标发送到 OpenTSDB 实例。 随着 OpenTSDB 2.0 的推出，发送指标的推荐方法是通过 HTTP API，它允许通过配置“http_batch_size”对指标进行批量处理。 该插件支持多个配置选项，包括指标前缀、服务器主机和端口规范、反向代理的 URI 路径自定义以及用于诊断与 OpenTSDB 通信问题的调试选项。 此插件在生成时间序列数据并且需要将其高效存储在可扩展的时间序列数据库（如 OpenTSDB）中的场景中特别有用，使其适用于广泛的监控和分析应用程序。

配置

MQTT

[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = [
    "telegraf/host01/cpu",
    "telegraf/+/mem",
    "sensors/#",
  ]
  # topic_tag = "topic"
  # qos = 0
  # connection_timeout = "30s"
  # keepalive = "60s"
  # ping_timeout = "10s"
  # max_undelivered_messages = 1000
  # persistent_session = false
  # client_id = ""
  # username = "telegraf"
  # password = "metricsmetricsmetricsmetrics"
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  # insecure_skip_verify = false
  # client_trace = false
  data_format = "influx"
  # [[inputs.mqtt_consumer.topic_parsing]]
  #   topic = ""
  #   measurement = ""
  #   tags = ""
  #   fields = ""
  #   [inputs.mqtt_consumer.topic_parsing.types]
  #      key = type

OpenTSDB

[[outputs.opentsdb]]
  ## prefix for metrics keys
  prefix = "my.specific.prefix."

  ## DNS name of the OpenTSDB server
  ## Using "opentsdb.example.com" or "tcp://opentsdb.example.com" will use the
  ## telnet API. "http://opentsdb.example.com" will use the Http API.
  host = "opentsdb.example.com"

  ## Port of the OpenTSDB server
  port = 4242

  ## Number of data points to send to OpenTSDB in Http requests.
  ## Not used with telnet API.
  http_batch_size = 50

  ## URI Path for Http requests to OpenTSDB.
  ## Used in cases where OpenTSDB is located behind a reverse proxy.
  http_path = "/api/put"

  ## Debug true - Prints OpenTSDB communication
  debug = false

  ## Separator separates measurement name from field
  separator = "_"

输入和输出集成示例

MQTT

1. 智能家居监控：使用 MQTT Consumer 插件监控智能家居设置中的各种传感器。 在此场景中，可以将插件配置为订阅不同设备的主题，例如温度、湿度和能耗。 通过聚合这些数据，房主可以可视化趋势并接收异常模式的警报，从而提高家庭自动化系统的整体质量和效率。

2. 物联网环境传感：部署 MQTT Consumer 以收集来自分布在不同位置的传感器的环境数据。 例如，这可以包括来自空气质量传感器、温度传感器和噪声水平计的读数。 可以配置插件以从 MQTT 主题中提取相关标签和字段，从而可以对大规模环境条件进行详细分析和报告，从而为城市规划或环境倡议提供更好的决策支持。

3. 实时车辆跟踪和遥测：将 MQTT Consumer 插件集成到车辆遥测系统中，该系统实时收集来自各种传感器的数据。 通过该插件，可以将与车辆性能、位置和燃油消耗相关的指标发送到集中式监控仪表板。 这种实时遥测数据使车队经理能够通过主动数据分析来优化路线、降低燃油成本并改进车辆维护计划。

4. 农业监控系统：利用此插件收集来自农业传感器的数据，这些传感器监控土壤湿度、作物健康状况和天气条件。 MQTT Consumer 可以订阅与农业设备和环境传感器相关的多个主题，使农民能够做出数据驱动的决策，以提高作物产量，同时节约资源，从而提高农业的可持续性。

OpenTSDB

1. 实时基础设施监控：利用 OpenTSDB 插件收集和存储来自各种基础设施组件的指标。 通过配置插件以将指标推送到 OpenTSDB，组织可以全面了解其基础设施的健康状况和随时间推移的性能。

2. 自定义应用程序指标跟踪：将 OpenTSDB 插件集成到自定义应用程序中，以跟踪关键绩效指标 (KPI)，例如响应时间、错误率和用户交互。 此设置允许开发人员和产品团队可视化应用程序性能趋势并做出数据驱动的决策。

3. 自动异常检测：结合机器学习算法利用该插件自动检测发送到 OpenTSDB 的时间序列数据中的异常。 通过持续监控传入的指标，系统可以训练模型，以便在潜在问题影响应用程序性能之前向用户发出警报。

4. 历史数据分析：使用 OpenTSDB 插件存储和分析历史性能数据，以进行容量规划和趋势分析。 这提供了对系统随时间推移的行为的宝贵见解，帮助团队了解使用模式并为未来的增长做好准备。

反馈

感谢您成为我们社区的一份子！ 如果您有任何一般性反馈或在这些页面上发现任何错误，我们欢迎并鼓励您提出意见。 请在 InfluxDB 社区 Slack 中提交您的反馈。