encresearch/mqtt-connector

镜像概述

encresearch/mqtt-connector是数据采集平台的客户端组件，作为MQTT客户端连接到MQTT服务器，订阅传感器等设备发送的数据，并将其持久化存储到InfluxDB数据库中，支持数据采集场景的端到端数据流转。

核心功能

• MQTT订阅：连接指定MQTT Broker，订阅预设主题的设备数据；
• 数据存储：将接收的结构化/非结构化数据写入InfluxDB，支持时序数据的高效存储；
• 轻量可靠：作为客户端组件，资源占用低，适配各类数据采集场景。

使用场景

• IoT设备数据采集：收集智能传感器（温湿度、空气质量等）的实时数据；
• 工业监控系统：存储生产设备运行状态、参数等时序数据；
• 环境监测平台：记录环境传感器的持续监测数据。

配置说明

需通过环境变量配置以下参数：

• MQTT_BROKER：MQTT服务器地址（如 mqtt://broker.example.com:1883）；
• MQTT_TOPIC：订阅的MQTT主题（如 sensors/#）；
• INFLUXDB_URL：InfluxDB服务地址（如 http://influxdb:8086）；
• INFLUXDB_DB：目标数据库名称（如 iot_data）；
• （可选）INFLUXDB_USER/INFLUXDB_PASSWORD：InfluxDB认证信息。

部署示例

Docker Run命令

bash
docker run -d \
  -e MQTT_BROKER=mqtt://your-mqtt-broker:1883 \
  -e MQTT_TOPIC=data/sensors \
  -e INFLUXDB_URL=http://your-influxdb:8086 \
  -e INFLUXDB_DB=iot_monitor \
  docker.xuanyuan.run/encresearch/mqtt-connector

Docker Compose示例

yaml
version: "3"
services:
  mqtt-connector:
    image: encresearch/mqtt-connector
    environment:
      MQTT_BROKER: mqtt://mqtt:1883
      MQTT_TOPIC: sensors/#
      INFLUXDB_URL: [***]
      INFLUXDB_DB: iot_data
    depends_on:
      - mqtt
      - influxdb
  mqtt:
    image: eclipse-mosquitto
  influxdb:
    image: influxdb:1.8
    volumes:
      - influxdb-data:/var/lib/influxdb
volumes:
  influxdb-data: