santoslabazon/rabbit_to_mongo_writer

santoslabazon/rabbit_to_mongo_writer 镜像说明

镜像概述

该镜像提供了一个轻量级服务，用于连接RabbitMQ消息队列与MongoDB数据库，实现JSON格式数据的实时读取与持久化存储。适用于需要将消息队列中的数据同步到数据库的场景，简化数据流转链路。

核心功能

1. 监听指定RabbitMQ队列，自动读取JSON格式消息
2. 将读取的JSON数据批量或单条写入MongoDB指定集合
3. 支持配置RabbitMQ与MongoDB的连接参数（主机、端口、认证信息等）
4. 异常处理机制：连接中断自动重连、数据写入失败重试

使用场景

• 日志数据收集：将RabbitMQ中的应用日志消息持久化到MongoDB进行分析
• 微服务数据同步：微服务间通过RabbitMQ传递的业务数据存储到MongoDB
• 实时数据处理：流数据经过RabbitMQ缓冲后写入MongoDB供后续查询

配置说明

需通过环境变量配置连接信息：

部署示例

Docker Run命令

bash
docker run -d \
  --name rabbit-mongo-writer \
  -e RABBITMQ_HOST=rabbitmq \
  -e RABBITMQ_PORT=5672 \
  -e RABBITMQ_QUEUE=user-events \
  -e RABBITMQ_USER=guest \
  -e RABBITMQ_PASS=guest \
  -e MONGO_URI=mongodb://mongo:27017 \
  -e MONGO_DB=user-db \
  -e MONGO_COLLECTION=events \
  docker.xuanyuan.run/santoslabazon/rabbit_to_mongo_writer

Docker Compose示例

yaml
version: '3'
services:
  rabbitmq:
    image: rabbitmq:3-management
    ports:
      - "5672:5672"
      - "***:***"
    environment:
      RABBITMQ_DEFAULT_USER: guest
      RABBITMQ_DEFAULT_PASS: guest
  
  mongo:
    image: mongo
    ports:
      - "27017:27017"
  
  writer:
    image: santoslabazon/rabbit_to_mongo_writer
    environment:
      RABBITMQ_HOST: rabbitmq
      RABBITMQ_PORT: 5672
      RABBITMQ_QUEUE: user-events
      RABBITMQ_USER: guest
      RABBITMQ_PASS: guest
      MONGO_URI: mongodb://mongo:27017
      MONGO_DB: user-db
      MONGO_COLLECTION: events
    depends_on:
      - rabbitmq
      - mongo