zivillian/ora2mqtt Docker 镜像 - 轩辕镜像 | Docker 镜像高效稳定拉取服务

镜像概述

ora2mqtt 镜像基于 GitHub 项目 zivillian/ora2mqtt 构建，提供轻量级解决方案，实现 Oracle 数据库与 MQTT 消息代理之间的数据同步。通过该工具可将 Oracle 数据库中的指定表数据实时或定时推送至 MQTT broker，适用于物联网数据集成、跨系统数据同步等场景。

核心功能

• Oracle 数据库连接管理：支持配置 Oracle 数据库连接参数（主机、端口、SID、用户名、密码），实现稳定的数据读取
• MQTT 消息发布：支持连接至 MQTT broker（如 Mosquitto、EMQX 等），支持 MQTT 协议基础认证及 TLS 加密连接
• 灵活同步策略：支持定时轮询（可配置间隔秒数）或实时触发（基于数据库事务日志）两种同步模式
• 数据格式自定义：支持将数据库记录转换为 JSON 格式，并可自定义 MQTT 消息主题及负载结构
• 轻量级部署：基于 Docker 容器化设计，无复杂依赖，支持通过环境变量快速配置

使用场景

• 物联网数据集成：将 Oracle 数据库中的设备状态、传感器历史数据同步至 MQTT 网络，供物联网终端或平台实时消费
• 跨系统数据共享：作为数据桥梁，将 Oracle 业务数据（如订单、库存）同步至依赖 MQTT 协议的监控系统、数据分析平台
• 实时数据备份：通过 MQTT 消息记录数据库关键表变更，实现轻量化数据备份或操作审计跟踪

使用方法

基础部署（docker run 命令）

bash
docker run -d \
  --name ora2mqtt \
  -e ORACLE_HOST=oracle-db.example.com \
  -e ORACLE_PORT=1521 \
  -e ORACLE_SID=ORCLCDB \
  -e ORACLE_USER=sync_user \
  -e ORACLE_PASSWORD=SyncPass123 \
  -e MQTT_BROKER=mqtt://broker.example.com:1883 \
  -e MQTT_USER=mqtt_sync \
  -e MQTT_PASSWORD=MqttPass456 \
  -e MQTT_TOPIC=oracle/sync/data \
  -e SYNC_TABLE=PRODUCTION_STATUS \
  -e SYNC_FIELDS=DEVICE_ID,STATUS,TIMESTAMP \
  -e SYNC_INTERVAL=30 \
  zivillian/ora2mqtt

环境变量配置说明

docker-compose 部署示例

yaml
version: '3.8'
services:
  ora2mqtt:
    image: zivillian/ora2mqtt
    container_name: ora2mqtt-service
    restart: unless-stopped
    environment:
      - ORACLE_HOST=oracle-db
      - ORACLE_PORT=1521
      - ORACLE_SID=ORCLCDB
      - ORACLE_USER=scott
      - ORACLE_PASSWORD=tiger
      - MQTT_BROKER=mqtt://mosquitto:1883
      - MQTT_TOPIC=oracle/emp/data
      - SYNC_TABLE=EMP
      - SYNC_FIELDS=EMPNO,ENAME,JOB,SAL,HIREDATE
      - SYNC_INTERVAL=30
      - LOG_LEVEL=INFO
    depends_on:
      - oracle-db
      - mosquitto

  oracle-db:
    image: gvenzl/oracle-xe:21-slim
    environment:
      - ORACLE_PASSWORD=tiger
      - APP_USER=scott
      - APP_USER_PASSWORD=tiger
    ports:
      - "1521:1521"

  mosquitto:
    image: eclipse-mosquitto:2.0
    ports:
      - "1883:1883"
    volumes:
      - ./mosquitto/config:/mosquitto/config

注意事项

• 实时触发模式（SYNC_INTERVAL=0）依赖 Oracle 数据库开启日志挖掘功能，需确保数据库已配置归档日志且用户具备相关权限
• 首次运行时建议设置 LOG_LEVEL=DEBUG，便于排查 Oracle 连接或 MQTT 连接异常
• 生产环境建议使用 mqtts:// 协议（MQTT over TLS）并配置证书，增强数据传输安全性