reap/mqtt-influxdb-bridge

MQTT-InfluxDB桥接应用

镜像概述

本镜像提供一个桥接工具，用于监听MQTT broker的消息并将其存储到InfluxDB中，实现MQTT数据到时序数据库的无缝传输，适用于物联网数据采集、监控系统等场景。

核心功能

• 监听指定MQTT broker的消息
• 将MQTT消息按规则映射到InfluxDB的数据库、系列和标签（如topic home/room1/temperature对应数据库home、系列temperature、标签source=room1）
• 支持通过命令行参数或环境变量配置连接信息

使用场景

• 物联网设备数据采集：将传感器（如温度、湿度传感器）发送的MQTT消息存储到InfluxDB进行后续分析
• 监控系统数据存储：收集设备状态等MQTT消息并持久化到时序数据库
• 数据同步：实现MQTT与InfluxDB之间的数据实时同步

配置说明

命令行参数

运行时需提供两个核心参数：

• broker：MQTT broker的连接字符串（如tcp://localhost:1883）
• db：InfluxDB的连接字符串（如http://localhost:8086）

示例：

bash
./mqtt-influx-bridge -broker=tcp://localhost:1883 -db=http://localhost:8086

环境变量

也可通过环境变量配置：

• BROKER：MQTT broker连接字符串
• DB：InfluxDB连接字符串

示例：

bash
BROKER=tcp://localhost:1883 DB=http://localhost:8086 ./mqtt-influx-bridge

Docker部署示例

使用环境变量配置并运行镜像：

bash
docker run -e BROKER="tcp://mqtt-broker:1883" -e DB="http://influxdb:8086" reap/mqtt-influxdb-bridge

若需配合MQTT broker和InfluxDB使用，可通过docker-compose编排：

yaml
version: '3'
services:
  mqtt-broker:
    image: eclipse-mosquitto
    ports:
      - "1883:1883"
  influxdb:
    image: influxdb:1.8
    ports:
      - "8086:8086"
  bridge:
    image: reap/mqtt-influxdb-bridge
    environment:
      - BROKER=tcp://mqtt-broker:1883
      - DB=http://influxdb:8086
    depends_on:
      - mqtt-broker
      - influxdb