7

我有下一个情况。我在不同的服务器上有两个 mongodb 实例。例如

Mongodb instance on server "one" (host1:27017) with database: "test1"
Mongodb instance on server "two" (host2:27017) with database: "test2"

现在，我需要将“host1:27017”中的“test1”数据库与“host2:27017”中的“test2”同步。

“同步”是指下一个：

  1. 如果“test2”中不存在“test1”数据库中的某些集合，则应将该集合完全复制到“test1”数据库中。

  2. 如果集合中的某些记录在“test2”数据库中不存在，则必须添加否则更新。如果记录在“test1”数据库的A集合中不存在，但在“test2”数据库的A集合中存在，则必须从“test2”中删除记录。

顺便说一句，这里有问题。例如：“test1”数据库具有包含以下文档的集合“A”：

{
 _id: "1",
 name: "some name"
}

“test2”数据库具有包含以下文档的集合“A”：

{
 _id: "1",
 name: "some name"
}

{
 _id: "2",
 name: "some name2"
}

如果我执行 db.copyDatabase('test1', 'test2', "host2:27017") 我得到错误：

"errmsg" : "异常：E11000 重复键错误索引：test1.A.$ id dup key: { : \"1\" }"

与cloneDatabase命令相同。我该如何解决？

一般来说，同步数据库的方法有哪些？我知道最简单的方法是将文件从一台服务器复制到另一台服务器，但也许有更好的方法。

请帮忙。我是mongo的新人。谢谢。

4

2 回答 2

1

我没有尝试过，但是当前的 MongoDB 文档描述了一个等效于主从复制的复制集：

使用副本集部署主从等效项

如果您想要一个类似于主从复制的复制配置，使用副本集，请考虑以下副本配置文档。在此部署中 hosts 和 1提供大致相当于两个实例主从部署的复制：

{
   _id : 'setName',
   members : [
              { _id : 0, host : "<master>", priority : 1 },
              { _id : 1, host : "<slave>", priority : 0, votes : 0 }
  ]
}

有关副本集配置的更多信息，请参阅副本集配置。

于 2013-07-06T16:17:05.603 回答
1

使用 _id 而不是 id。无需在您的模型中声明它。

如果你有很多服务器

我在每台服务器上使用了一个小的 prehook，它创建了一个受控的唯一 _id。mongoose _id 的构建非常合乎逻辑（https://docs.mongodb.com/manual/reference/method/ObjectId/#ObjectIDs-BSONObjectIDSpecification），数字 0,6 是机器标识符。我只是控制这些数字，因为我有多个服务器，并且我想确保没有勾结。如果你只有几个，不这样做可能没有风险。即使在我的情况下，我也认为这太偏执了。

exports.useProcessId = ()->
  return process.env.INSTANCE_PROCESS_ID? && process.env.INSTANCE_PROCESS_ID.length == 4

exports.manipulateMongooseId = (id) ->
  id = id.toString()
  newId = new ObjectId(id.slice(0,6) + process.env.INSTANCE_PROCESS_ID + id.slice(10,24))
  return newId

图式

mymOdelSchema.pre('save', (next) ->
  data = @
  async.parallel
    myModel: (next)->
      myModelValidator.base(data, next)
    changeMongooseId: (next)->
      if useProcessId && instanceType == 'manager' then processIdConfig.changeMongooseId(data, next) else return next()
    (err)->
      return

 next new Error(err) if err?
      return next()
)
于 2017-05-16T07:17:33.783 回答