chesapeaketechnology/mqtt-azure-event-hub-connector

MQTT 到 Azure Event Hubs 连接器

镜像概述和主要用途

该Docker容器运行一个Java应用程序，用于从MQTT Broker拉取消息并将消息流式传输到Azure Event Hubs，实现MQTT协议与Azure Event Hubs之间的消息桥接。

源代码

容器源代码可在以下地址获取：https://github.com/chesapeaketechnology/mqtt-azure-event-hubs-connector

核心功能和特性

• 实现MQTT Broker与Azure Event Hubs之间的消息传输
• 通过配置文件自定义连接参数
• 支持日志目录挂载，方便日志管理和查看

使用场景和适用范围

适用于需要将MQTT协议的设备数据或消息转发至Azure Event Hubs的场景，如物联网设备数据收集、实时数据处理管道构建等。

详细使用方法和配置说明

基本运行命令

执行以下命令可运行Docker容器：

bash
docker run docker.xuanyuan.run/chesapeaketechnology/mqtt-azure-event-hub-connector:latest

注意：上述命令使用默认配置（多为空值），实际部署需指定配置文件和日志目录。

完整部署步骤

1. 创建目录结构

   bash
   mkdir mqtt-docker-connector
   cd mqtt-docker-connector
   mkdir config log
   

2. 创建配置文件

   • 在config目录下创建mqttconnector.conf文件
   • 配置文件参数参考示例：src/main/resources/reference.conf

3. 启动容器

   bash
   docker run --name MqttAzureConnector \
     -v $(pwd)/config:/mqtt-azure-connector/config \
     -v $(pwd)/log:/mqtt-azure-connector/log \
     docker.xuanyuan.run/chesapeaketechnology/mqtt-azure-event-hub-connector:latest
   

Docker部署示例

上述完整部署步骤中的docker run命令即为标准部署示例，通过挂载config目录（包含配置文件）和log目录（用于日志存储）实现容器的自定义配置和持久化日志。