这不是大规模实时查询的推荐配置。为了进行查询和压缩优化、高速摄取和高可用性，您可能需要考虑 MQTT 和 InfluxDB。
5B+
Telegraf 下载量
#1
时序数据库
来源：DB Engines
1B+
InfluxDB 下载量
2,800+
贡献者
目录
输入和输出集成概述
MQTT Telegraf 插件旨在从指定的 MQTT 主题读取数据并创建指标，使用户能够利用 MQTT 进行实时数据收集和监控。
Graylog 插件允许您将 Telegraf 指标发送到 Graylog 服务器，并使用 GELF 格式进行结构化日志记录。
集成详情
MQTT
MQTT 插件允许从指定的 MQTT 主题读取指标，并使用支持的输入数据格式创建指标。此插件作为服务输入运行，它侦听传入的指标或事件，而不是像普通插件那样按设定的时间间隔收集它们。该插件的灵活性通过支持各种 Broker URL、主题和连接功能（包括服务质量 (QoS) 级别和持久会话）得到增强。其配置选项包含全局设置，可用于修改指标并有效处理启动错误。它还支持用于保护用户名和密码选项的密钥存储配置，从而确保与 MQTT 服务器的安全连接。
Graylog
Graylog 插件旨在用于使用 GELF（Graylog 扩展日志格式）格式将指标发送到 Graylog 实例。GELF 有助于标准化日志记录数据，使系统更容易发送和分析日志。该插件遵循 GELF 规范，该规范规定了有效负载中特定字段的要求。值得注意的是，时间戳必须采用 UNIX 格式，如果存在，插件会将时间戳原样发送到 Graylog，而无需进行任何更改。如果省略，它会自动生成时间戳。此外，任何未由规范明确定义的额外字段都将以一个下划线为前缀，这有助于保持数据井井有条并符合 GELF 的要求。此功能对于实时监控应用程序和基础设施的用户尤其有价值，因为它允许跨多个系统进行无缝集成和改进的可视性。
配置
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
Graylog
[[outputs.graylog]]
## Endpoints for your graylog instances.
servers = ["udp://127.0.0.1:12201"]
## Connection timeout.
# timeout = "5s"
## The field to use as the GELF short_message, if unset the static string
## "telegraf" will be used.
## example: short_message_field = "message"
# short_message_field = ""
## According to GELF payload specification, additional fields names must be prefixed
## with an underscore. Previous versions did not prefix custom field 'name' with underscore.
## Set to true for backward compatibility.
# name_field_no_prefix = false
## Connection retry options
## Attempt to connect to the endpoints if the initial connection fails.
## If 'false', Telegraf will give up after 3 connection attempt and will
## exit with an error. If set to 'true', the plugin will retry to connect
## to the unconnected endpoints infinitely.
# connection_retry = false
## Time to wait between connection retry attempts.
# connection_retry_wait_time = "15s"
## Optional TLS Config
# tls_ca = "/etc/telegraf/ca.pem"
# tls_cert = "/etc/telegraf/cert.pem"
# tls_key = "/etc/telegraf/key.pem"
## Use TLS but skip chain & host verification
# insecure_skip_verify = false
输入和输出集成示例
MQTT
-
智能家居监控：使用 MQTT Consumer 插件来监控智能家居设置中的各种传感器。在此场景中，插件可以配置为订阅不同设备的主题，例如温度、湿度和能耗。通过聚合这些数据，房主可以可视化趋势并接收异常模式的警报，从而提高家庭自动化系统的整体质量和效率。
-
物联网环境传感：部署 MQTT Consumer 以收集来自分布在不同位置的传感器的环境数据。例如，这可以包括来自空气质量传感器、温度传感器和噪声水平计的读数。该插件可以配置为从 MQTT 主题中提取相关标签和字段，从而可以对大规模的环境条件进行详细分析和报告，为城市规划或环境倡议提供更好的决策支持。
-
实时车辆跟踪和遥测：将 MQTT Consumer 插件集成到车辆遥测系统中，该系统实时收集来自各种传感器的数据。借助该插件，与车辆性能、位置和燃油消耗相关的指标可以发送到中央监控仪表板。这种实时遥测数据使车队经理能够通过主动数据分析来优化路线、降低燃油成本并改进车辆维护计划。
-
农业监控系统：利用此插件收集来自农业传感器的数据，这些传感器监控土壤湿度、作物健康状况和天气状况。MQTT Consumer 可以订阅与农业设备和环境传感器相关的多个主题，使农民能够做出数据驱动的决策，以提高作物产量，同时节约资源，从而提高农业的可持续性。
Graylog
-
增强云应用程序的日志管理：使用 Graylog Telegraf 插件来聚合来自跨多个服务器云部署的应用程序的日志。通过集成此插件，团队可以将日志记录数据集中化，从而更轻松地排除问题、监控应用程序性能并保持符合日志记录标准。
-
实时安全监控：利用 Graylog 插件来收集安全相关的指标和日志，并将它们发送到 Graylog 服务器进行实时分析。这使安全团队能够通过关联基础设施内各种来源的日志，快速识别异常、跟踪潜在的漏洞并及时响应事件。
-
动态警报和通知系统：实施 Graylog 插件以增强基础设施中的警报机制。通过将指标发送到 Graylog，团队可以根据日志模式或意外行为设置动态警报，从而实现主动监控和快速事件响应策略。
-
跨平台日志整合：使用 Graylog 插件来促进跨平台日志整合，跨越本地、混合和云等不同环境。通过以 GELF 格式标准化日志记录，组织可以确保一致的监控和故障排除实践，而无需考虑其服务托管在何处。
反馈
感谢您成为我们社区的一份子！如果您有任何一般性反馈或在这些页面上发现了任何错误，我们欢迎并鼓励您提出意见。请在 InfluxDB 社区 Slack 中提交您的反馈。
