如何在本地搭建MongoDB Atlas云数据库从节点副本并实现本地变更自动同步至主库？

阿华AIGC实验室

2026-5-7

实现本地与MongoDB Atlas免费层数据库的双向自动同步

嘿，我来帮你梳理下怎么实现这个需求——首先得明确一个关键限制：MongoDB Atlas免费层（M0）是托管的三节点副本集，你没法直接把本地节点加入到这个托管的副本集里，因为Atlas的网络和托管策略不允许外部节点成为它的副本集成员。所以咱们得换个思路，用双向实时同步的方案来实现本地和Atlas主库互相自动同步变更。

一、前期准备工作

先把基础工作做好，避免后续踩坑：

本地安装和Atlas集群同版本的MongoDB社区版（比如Atlas用5.0，本地也装5.0），版本不一致容易出现兼容性问题
登录Atlas控制台，在「网络访问」里把本地公网IP加入白名单（测试阶段可以临时允许0.0.0.0/0，生产环境一定要限制具体IP）
复制Atlas集群的主节点连接字符串（带用户名和密码的完整串，格式类似mongodb+srv://<user>:<password>@cluster0.mongodb.net/）
开启本地MongoDB的复制功能：修改mongod.conf配置文件，添加以下内容，然后重启本地MongoDB服务
```
replication:
  replSetName: "localRepl"
```
重启后连接到本地MongoDB，执行初始化副本集的命令：
```
rs.initiate()
```

二、方案1：用MongoDB Compass双向同步（简单易上手）

如果你不想写代码，MongoDB Compass的可视化同步工具是最佳选择，它基于Change Streams实现实时同步，操作起来很直观：

打开MongoDB Compass，分别连接到Atlas集群和本地MongoDB实例
第一步：同步Atlas到本地
1. 在Atlas的连接窗口右上角，点击「Sync」按钮
2. 选择源为Atlas的目标数据库/集合，目标为本地MongoDB的对应库/集合
3. 勾选「连续同步（Continuous Sync）」，开启后Atlas的所有变更会实时同步到本地
第二步：同步本地到Atlas
1. 切换到本地MongoDB的连接窗口，同样点击右上角的「Sync」按钮
2. 选择源为本地的库/集合，目标为Atlas的对应库/集合
3. 同样勾选「连续同步」，开启后本地的变更会自动推送到Atlas

小提醒：这种方案要注意冲突问题——如果两边同时修改同一条数据，最后写入的会覆盖之前的。如果你的业务有冲突场景，得提前定义好冲突处理规则（比如优先保留Atlas的变更）。

三、方案2：自定义脚本实现双向同步（灵活可控）

如果需要更灵活的冲突处理、自定义逻辑，或者要集成到现有系统里，可以用MongoDB的Change Streams API写脚本，比如用Node.js或Python：

示例：Node.js基础同步脚本

先安装依赖：
```
npm install mongodb
```

编写核心同步逻辑（你可以根据业务需求扩展冲突处理、错误重试等功能）：

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

// 替换成你的Atlas和本地连接串
const atlasUri = 'mongodb+srv://<user>:<password>@cluster0.mongodb.net/';
const localUri = 'mongodb://localhost:27017/';
// 替换成你要同步的数据库和集合名
const targetDb = 'your-db-name';
const targetColl = 'your-coll-name';

// 通用同步函数：监听源的变更，同步到目标
async function syncChanges(sourceUri, targetUri) {
  const sourceClient = await MongoClient.connect(sourceUri);
  const targetClient = await MongoClient.connect(targetUri);

  const sourceColl = sourceClient.db(targetDb).collection(targetColl);
  const targetColl = targetClient.db(targetDb).collection(targetColl);

  console.log(`开始同步：从 ${sourceUri} 到 ${targetUri}`);
  // 监听Change Streams
  const changeStream = sourceColl.watch();
  for await (const change of changeStream) {
    try {
      switch (change.operationType) {
        case 'insert':
          await targetColl.insertOne(change.fullDocument);
          break;
        case 'update':
          await targetColl.updateOne(
            { _id: change.documentKey._id },
            { $set: change.updateDescription.updateFields }
          );
          break;
        case 'delete':
          await targetColl.deleteOne({ _id: change.documentKey._id });
          break;
        default:
          console.log(`暂不支持的操作类型：${change.operationType}`);
      }
      console.log(`已同步变更：${change.operationType} 文档 _id: ${change.documentKey._id}`);
    } catch (err) {
      console.error('同步出错：', err);
    }
  }
}

// 启动两个方向的同步
syncChanges(atlasUri, localUri);
syncChanges(localUri, atlasUri);