geokrety/basex-amqp-sync

geokrety-basex-amqp-sync 镜像文档

镜像概述

geokrety-basex-amqp-sync 是一个守护进程服务，作为 BaseX 数据库与 PostgreSQL 数据库之间的同步桥接工具。它通过 AMQP（高级消息队列协议）接收数据库变更事件，实现两个数据库之间的数据实时同步，确保数据一致性。

核心功能与特性

• 实时数据同步：通过 AMQP 消息队列实时捕获数据库变更事件并同步
• 双向数据桥接：支持 BaseX 与 PostgreSQL 之间的双向数据同步
• 消息队列集成：兼容标准 AMQP 协议，可与 RabbitMQ 等消息队列服务配合使用
• 错误处理机制：具备消息重试和错误日志记录功能，确保同步可靠性
• 轻量级设计：基于高效的守护进程模式运行，资源占用低

使用场景与适用范围

• 同时使用 BaseX（XML 数据库）和 PostgreSQL（关系型数据库）的应用系统
• 需要保持多数据库间数据一致性的业务场景
• 基于消息队列架构的分布式系统数据同步需求
• 对数据实时性要求较高的 XML 与关系数据混合存储环境

使用方法与配置说明

基本使用（Docker Run）

bash
docker run -d \
  --name basex-amqp-sync \
  -e AMQP_URI=amqp://user:password@rabbitmq:5672 \
  -e AMQP_QUEUE=basex-postgres-sync \
  -e POSTGRES_URI=postgresql://user:password@postgres:5432/dbname \
  -e BASEX_URI=http://basex:8984 \
  -e BASEX_USER=admin \
  -e BASEX_PASSWORD=admin \
  docker.xuanyuan.run/geokrety/geokrety-basex-amqp-sync

Docker Compose 配置

yaml
version: '3'
services:
  sync-daemon:
    image: docker.xuanyuan.run/geokrety/geokrety-basex-amqp-sync
    restart: always
    environment:
      - AMQP_URI=amqp://rabbitmq_user:rabbitmq_password@rabbitmq:5672
      - AMQP_QUEUE=database-sync-events
      - AMQP_EXCHANGE=db.events
      - AMQP_ROUTING_KEY=sync.*
      - POSTGRES_URI=postgresql://pg_user:pg_password@postgres:5432/geokrety
      - POSTGRES_SSL_MODE=require
      - BASEX_URI=http://basex:8984
      - BASEX_USER=admin
      - BASEX_PASSWORD=secure_password
      - SYNC_INTERVAL=5s
      - LOG_LEVEL=info
    depends_on:
      - rabbitmq
      - postgres
      - basex

环境变量配置说明

注意事项

• 确保 AMQP 服务、BaseX 和 PostgreSQL 服务均已正确配置并可访问
• 首次运行前建议备份两个数据库的数据
• 高并发场景下可能需要调整消息队列的消费者数量和预取设置
• 生产环境中应使用非默认的数据库凭证，并启用 SSL 加密连接