MQTT 和 VictoriaMetrics 集成

输入和输出集成概述

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

此插件使 Telegraf 能够使用 InfluxDB 行协议直接将指标高效地写入 VictoriaMetrics，从而利用 VictoriaMetrics 的性能和可扩展性功能来处理大规模时间序列数据。

集成详情

MQTT

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

VictoriaMetrics

VictoriaMetrics 支持直接摄取 InfluxDB 行协议中的指标，这使得此插件成为高效实时指标存储和检索的理想选择。该集成结合了 Telegraf 广泛的指标收集能力与 VictoriaMetrics 优化的存储和查询功能，包括压缩、快速摄取率和高效的磁盘利用率。此插件非常适合云原生和大规模监控场景，具有简单性、强大的性能和高可靠性，为大量指标实现高级操作洞察和长期存储解决方案。

配置

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

VictoriaMetrics

[[outputs.influxdb]]
  ## URL of the VictoriaMetrics write endpoint
  urls = ["http://localhost:8428"]

  ## VictoriaMetrics accepts InfluxDB line protocol directly
  database = "db_name"

  ## Optional authentication
  # username = "username"
  # password = "password"
  # skip_database_creation = true
  # exclude_retention_policy_tag = true
  # content_encoding = "gzip"

  ## Timeout for HTTP requests
  timeout = "5s"

  ## Optional TLS configuration
  # tls_ca = "/path/to/ca.pem"
  # tls_cert = "/path/to/cert.pem"
  # tls_key = "/path/to/key.pem"
  # insecure_skip_verify = false

输入和输出集成示例

MQTT

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

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

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

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

VictoriaMetrics

1. 云原生应用程序监控：将 Kubernetes 上部署的微服务的指标直接流式传输到 VictoriaMetrics。通过集中指标，组织可以跨动态演变的云环境执行实时监控、快速异常检测和无缝扩展。

2. 可扩展的物联网数据管理：使用该插件将来自物联网部署的传感器数据摄取到 VictoriaMetrics 中。这种方法有助于实时分析、预测性维护和高效管理海量传感器数据，同时最大限度地减少存储开销。

3. 金融系统性能跟踪：通过此插件利用 VictoriaMetrics 存储和分析来自金融系统的指标，捕获延迟、交易量和错误率。组织可以快速识别和解决性能瓶颈，确保高可用性和法规遵从性。

4. 跨环境性能仪表板：将来自各种基础设施组件（例如云实例、容器和物理服务器）的指标集成到 VictoriaMetrics 中。使用可视化工具，团队可以构建全面的仪表板，以实现端到端的性能可见性、主动故障排除和基础设施优化。

反馈

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