目录
输入和输出集成概述
MQTT Telegraf 插件旨在从指定的 MQTT 主题读取数据并创建指标，使用户能够利用 MQTT 进行实时数据收集和监控。
此插件使 Telegraf 能够将指标实时流式传输到 Grafana 仪表板，利用 Grafana Live 进行即时数据可视化和操作洞察。
集成详情
MQTT
MQTT 插件允许从指定的 MQTT 主题读取指标，并使用支持的输入数据格式创建指标。此插件作为服务输入运行，它监听传入的指标或事件，而不是像普通插件那样按设定的时间间隔收集它们。插件的灵活性通过支持各种代理 URL、主题和连接功能得到增强，包括服务质量 (QoS) 级别和持久会话。其配置选项包含全局设置，可有效修改指标和处理启动错误。它还支持用于保护用户名和密码选项的密钥存储配置，从而确保与 MQTT 服务器的安全连接。
Grafana
Telegraf 可以使用 Websocket 输出插件将实时数据发送到 Grafana。 Telegraf 收集的指标会立即推送到 Grafana 仪表板，从而实现实时可视化和分析。此插件非常适合需要低延迟、实时数据可视化的用例，例如操作监控、实时分析和即时事件响应场景。它支持身份验证标头、可自定义的数据序列化格式（如 JSON）以及通过 TLS 进行的安全通信，从而在动态、交互式仪表板环境中提供灵活性和易于集成性。
配置
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
Grafana
[[outputs.websocket]]
## Grafana Live WebSocket endpoint
url = "ws://localhost:3000/api/live/push/custom_id"
## Optional headers for authentication
# [outputs.websocket.headers]
# Authorization = "Bearer YOUR_GRAFANA_API_TOKEN"
## Data format to send metrics
data_format = "influx"
## Timeouts (make sure read_timeout is larger than server ping interval or set to zero).
# connect_timeout = "30s"
# write_timeout = "30s"
# read_timeout = "30s"
## Optionally turn on using text data frames (binary by default).
# use_text_frames = false
## 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
-
智能家居监控：使用 MQTT Consumer 插件来监控智能家居设置中的各种传感器。在这种情况下，可以将插件配置为订阅不同设备的主题，例如温度、湿度和能耗。通过聚合这些数据，房主可以可视化趋势并接收异常模式的警报，从而提高家庭自动化系统的整体质量和效率。
-
物联网环境传感：部署 MQTT Consumer 插件以收集分布在不同位置的传感器环境数据。例如，这可以包括来自空气质量传感器、温度传感器和噪声水平计的读数。可以将插件配置为从 MQTT 主题中提取相关的标签和字段，从而可以对大规模环境条件进行详细分析和报告，从而为城市规划或环境倡议提供更好的决策支持。
-
实时车辆跟踪和遥测：将 MQTT Consumer 插件集成到车辆遥测系统中，该系统实时收集来自各种传感器的数据。借助该插件，可以将与车辆性能、位置和燃油消耗相关的指标发送到中央监控仪表板。这种实时遥测数据使车队管理者能够通过主动数据分析来优化路线、降低燃油成本并改进车辆维护计划。
-
农业监控系统：利用此插件收集来自农业传感器的数据，这些传感器监控土壤湿度、作物健康状况和天气状况。 MQTT Consumer 可以订阅与农业设备和环境传感器相关的多个主题，使农民能够做出数据驱动的决策，以提高作物产量，同时节约资源，增强农业可持续性。
Grafana
-
实时基础设施仪表板：部署 Telegraf 将服务器健康指标直接流式传输到 Grafana 仪表板，使 IT 团队能够实时可视化基础设施性能。这种设置允许立即检测和响应关键系统事件。
-
交互式物联网监控：集成 Telegraf 收集的物联网设备指标，并将实时数据推送到 Grafana，从而创建动态和交互式仪表板，用于监控智慧城市项目或制造过程。这种实时可见性显着提高了响应能力和运营效率。
-
即时应用程序性能分析：将来自生产环境的应用程序指标实时流式传输到 Grafana 仪表板，使开发团队能够在部署期间快速检测和诊断性能瓶颈或异常，从而最大限度地减少停机时间并提高可靠性。
-
实时事件分析：在大型现场活动期间，利用 Telegraf 捕获实时观众或系统指标，并直接流式传输到 Grafana 仪表板。活动组织者可以动态监控并对不断变化的条件或趋势做出反应，从而显着提高观众参与度和运营决策能力。
反馈
感谢您成为我们社区的一份子！如果您有任何一般性反馈或在这些页面上发现任何错误，我们欢迎并鼓励您提出意见。请在 InfluxDB 社区 Slack 中提交您的反馈。
