全部产品
Search
文档中心

云数据库 MongoDB:使用MongoShake实现MongoDB实例间的延迟同步

更新时间:Mar 28, 2024

本文档介绍如何通过MongoShake实现实例间的延迟同步。

前提条件

MongoShake版本为2.4.6及以上。详情请参见MongoShake发布页面

背景信息

在使用MongoShake实时同步多个实例时,当用户在主实例中执行了误操作以后,MongoShake会将该误操作实时同步到从实例,导致最终只能通过数据恢复来复原。因此,MongoShake在2.4.6版本的更新中提供了设置延迟同步的参数,给主从实例之间的同步设置一段缓冲的时间,当主实例中执行了误操作后,可以在这段时间内关闭同步,并直接将业务切换到还未发生误操作的从实例。

说明

本文档着重介绍延迟同步参数incr_sync.target_delay,有关使用MongoShake的其他事项请参见使用MongoShake实现MongoDB实例间的单向同步

准备工作

  1. 为达到最理想的同步性能,请确保源端MongoDB副本集实例的网络类型为专有网络VPC,如果是经典网络,请切换成专有网络VPC。更多信息,请参见经典网络切换为专有网络

  2. 创建作为同步目标端的MongoDB副本集实例,在创建的时候请选择与源端MongoDB副本集实例相同的专有网络VPC,以获取最低的网络延迟。更多信息,请参见创建副本集实例

  3. 创建用于运行MongoShake的ECS实例,在创建的时候请选择与源端MongoDB副本集实例相同的专有网络VPC,以获取最低的网络延迟。更多信息,请参见创建ECS实例

  4. 将ECS的内网IP地址加入至源端和目标端MongoDB实例的白名单中,并确保ECS可以连接源端和目标端MongoDB实例。 更多信息,请参见修改白名单

说明

如果您没有达到上述网络类型的要求,可以分别申请源端和目标端MongoDB实例的公网连接地址,并将ECS的公网地址加入至源端和目标端MongoDB实例的白名单中,通过公网地址进行同步操作。更多信息,请参见申请公网连接地址修改白名单

搭建MongoDB间的延迟同步架构

本示例以ECS上的Ubuntu系统为例介绍如何搭建延迟同步架构。详情请参见使用MongoShake实现MongoDB实例间的单向同步

  1. 登录ECS实例,具体请参见登录ECS实例

  2. 执行如下命令格式下载MongoShake程序。

    wget 最新版MongoShake包下载地址

    示例:

    wget https://github.com/alibaba/MongoShake/releases/download/release-v2.0.7-20190817/mongo-shake-2.0.7.tar.gz
    说明

    最新版本的MongoShake包下载地址请参见releases页面

  3. 执行如下命令格式解压MongoShake程序。

    tar xvf mongoshake包文件名

    示例:

    tar xvf mongo-shake-2.0.7.tar.gz
  4. 执行vi collector.conf命令配置MongoShake。各参数说明请参见MongoShake参数表。找到incr_sync.target_delay参数,根据实际业务需求设置该参数的值,单位为秒。本示例中将延迟时间设置为30分钟。

    incr_sync.target_delay = 1800
  5. 保存并退出collector.conf文件,至此延迟同步架构已经搭建完毕。

  6. 执行如下命令使用配置好的collector.conf文件开启同步,并打印日志信息。

    ./collector.linux -conf=collector.conf -verbose
    说明

    此时您在主实例中执行的任何更改,都将会在30分钟后同步到从实例。

误操作后切换主从实例

在主实例中日常执行CURD操作时,可能会存在某条语句误写入等误操作的情况发生,此时您可以通过下列步骤将业务切换到还没有发生误操作的从实例中。

  1. 通过查询MongoDB的操作日志(oplog)定位到误操作发生的时间点。例如:您可以通过执行如下命令来查询2020年06月01日至2020年06月02日之间所有的操作日志。关于查询oplog的详情请参见MongoDB官方文档

    use local #切换到local数据库
    db.oplog.rs.find({"o.createTime": {$gte:new Date(2020,6,1),$lte:new Date(2020,6,2)}}) #根据条件查看oplog。
  2. 通过RESTful接口远程向MongoShake注入ExitPoint参数来实现在指定时间点终止MongoShake程序的目的。命令格式如下:

    curl -X POST --data '{"ExitPoint": <Unix时间戳>}' <MongoShake服务器ID>:<端口号>/sentinel/options

    示例:

    curl -X POST --data '{"ExitPoint": 1593534600}' 127.0.0.1:9100/sentinel/options
    说明

    1593534600是Unix时间戳,表示2020年06月30日16:30:00。MongoShake同步到这个时间点后将会自动退出。

  3. 执行vi collector.conf命令打开配置文件,将原主从实例的地址调换。详细操作方法请参见使用MongoShake实现MongoDB实例间的单向同步

  4. 执行如下命令使用配置好的collector.conf文件重新开启同步,并打印日志信息。

    ./collector.linux -conf=collector.conf -verbose
  5. 将业务切换到最新的主实例上,完成主从实例切换操作。

监控MongoShake状态

详情请参见监控MongoShake状态