encresearch/connector

encresearch/connector镜像说明

镜像概述

encresearch/connector是一个轻量级API服务镜像，专注于物联网场景下的传感器数据处理：通过MQTT协议接收设备上传的传感器数据，并将数据可靠地存储到InfluxDB时序数据库中，为后续数据分析、监控提供基础支持。

核心功能

• MQTT数据接收：支持连接MQTT broker，订阅指定主题获取传感器数据；
• InfluxDB存储：将接收的结构化/半结构化数据写入InfluxDB，支持数据库认证与多测量点配置；
• 稳定可靠：内置重连机制，确保MQTT连接中断后自动恢复，避免数据丢失。

使用场景

• 小型物联网项目的传感器数据采集后端；
• 环境监测系统的实时数据存储；
• 工业设备状态数据的收集与存档。

配置说明

需通过环境变量配置关键参数：

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

部署示例

Docker Run命令

bash
docker run -d \
  --name connector \
  -e MQTT_BROKER=mqtt://localhost:1883 \
  -e MQTT_TOPIC=sensors/temperature \
  -e INFLUXDB_URL=http://localhost:8086 \
  -e INFLUXDB_DB=iot_data \
  encresearch/connector

Docker Compose示例

yaml
version: "3"
services:
  connector:
    image: encresearch/connector
    environment:
      MQTT_BROKER: mqtt://mqtt:1883
      MQTT_TOPIC: sensors/#
      INFLUXDB_URL: [***]
      INFLUXDB_DB: sensor_db
    depends_on:
      - mqtt
      - influxdb
  mqtt:
    image: eclipse-mosquitto:latest
  influxdb:
    image: influxdb:2.7
    volumes:
      - influxdb_data:/var/lib/influxdb2
volumes:
  influxdb_data: