如何从MQTT向Prometheus发送Apache Spark Plug格式的动态指标？

让MQTT2Prometheus支持动态指标的方法 #

• 利用Spark Plug消息结构特性：Spark Plug消息内置指标元数据（命名空间、设备ID、指标名等），可配置MQTT2Prometheus订阅Spark Plug主题通配符（如spBv1.0/#），通过模板化规则从消息Payload中动态提取指标名和数值，无需预先硬编码指标列表。
• 自定义源码改造：官方MQTT2Prometheus不支持动态解析时，可fork项目源码，添加Spark Plug Protobuf解析模块，自动遍历消息中的所有指标字段，生成对应的Prometheus时间序列。
• 动态配置重载：使用支持热重载的分支版本，结合配置模板工具（如Consul Template）实时生成包含新指标的配置文件，触发服务热重载实现动态适配。

替代工具选项 #

• Prometheus MQTT Adapter：支持通过JSONPath/Protobuf解析规则从MQTT消息中动态提取指标，自动创建Prometheus指标，无需预先定义所有指标名称，天然适配Spark Plug格式。
• Grafana Agent：内置MQTT数据采集能力，支持动态解析Spark Plug消息，可直接推送数据至Prometheus或Grafana Cloud，配置灵活度更高。
• 自定义脚本：用Python/Go编写轻量订阅脚本，借助Spark Plug Protobuf库解析消息，通过Prometheus Pushgateway推送指标，或直接暴露HTTP metrics端点，完全自定义适配动态场景。

内容的提问来源于stack exchange，提问作者Vipin Dubey