如何同步两个不同平台的MongoDB数据库products集合

1. MongoDB Change Streams + 自定义同步服务 #

Change Streams是MongoDB原生的变更监听功能，能实时捕获生产库products集合的增、删、改操作。你可以写个轻量服务（比如用Node.js、Python），连接生产库开启Change Stream，捕获到变更后直接同步到开发库对应集合。

• 核心逻辑：监听生产库的变更事件，解析事件类型（insert/update/delete），在开发库执行对应操作
• 示例代码片段（Node.js）：

const { MongoClient } = require('mongodb');

// 替换为实际的连接字符串
const prodUri = 'mongodb+srv://<prod-account>:<prod-pass>@<atlas-cluster>/';
const devUri = 'mongodb://<ec2-ip>:27017/';

async function startSync() {
  const prodClient = new MongoClient(prodUri);
  const devClient = new MongoClient(devUri);
  
  await prodClient.connect();
  await devClient.connect();
  
  const prodProducts = prodClient.db('<prod-db-name>').collection('products');
  const devProducts = devClient.db('<dev-db-name>').collection('products');
  
  // 开启变更流监听
  const changeStream = prodProducts.watch();
  
  for await (const change of changeStream) {
    switch(change.operationType) {
      case 'insert':
        await devProducts.insertOne(change.fullDocument);
        break;
      case 'update':
        await devProducts.updateOne(
          { _id: change.documentKey._id },
          { $set: change.updateDescription.updateFields }
        );
        break;
      case 'delete':
        await devProducts.deleteOne({ _id: change.documentKey._id });
        break;
    }
  }
}

startSync().catch(console.error);

• 部署：把这个服务部署到能同时访问两个库的服务器（比如你的EC2实例），用PM2或systemd托管，保证服务持续运行。

2. MongoDB Atlas触发器（Atlas Trigger） #

因为生产库在Atlas，可以直接用Atlas自带的数据库触发器实现同步：

• 配置一个数据库触发器，指定监听生产库products集合的变更事件
• 在触发器的函数代码里编写同步逻辑，直接把变更推送到EC2上的开发库
• 优势：不用自己维护额外服务，Atlas托管触发器运行，只需确保EC2的安全组允许Atlas的IP访问MongoDB端口。

3. 复制集同步（全库/单集合可选） #

如果EC2和Atlas集群网络连通性稳定，可以把开发库设为生产库的副本节点：

• 若只需要同步products集合，可配置复制集的集合过滤规则，只同步指定集合
• 注意：需确保EC2上的MongoDB版本和Atlas集群版本一致，同时要在Atlas控制台申请添加外部副本节点的权限。

4. CDC工具（如Debezium） #

如果需要更复杂的同步逻辑（比如数据转换、多集合同步），可以用Debezium这类变更数据捕获工具：

• Debezium捕获MongoDB的变更事件，发送到消息队列（如Kafka），再由消费者服务把事件同步到开发库
• 适合大型、多场景的同步需求，但部署和配置成本相对高一些。

内容的提问来源于stack exchange，提问作者Digvijay Singh Thakur