本章节主要介绍导入过程存储倾斜即时检测的最佳实践。 导入过程中对DN导入行数进行统计，导入完成后计算倾斜率，超过一定阈值时，立即进行告警。倾斜率通过（DN导入行数最大值DN导入行数最小值）/导入总行数计算。目前，只支持INSERT和COPY导入。 说明 必须设置enablestreamoperatoron，确保计划下发到DN，DN一次性返回导入行数，从而可以在CN计算倾斜率。 使用方法 1.设置参数（表倾斜告警阈值tableskewnesswarningthreshold和表倾斜告警最小行数tableskewnesswarningrows）； −表倾斜告警阈值取值范围0~1，默认值为1，即关闭状态，取其他值时为开启状态。 −表倾斜告警最小行数取值范围0~2147483647，默认值为100,000。当导入总行数超过该值与导入DN数之积时，才可能触发告警，从而不会在小数据量导入的场景进行无意义的告警。 show tableskewnesswarningthreshold; set tableskewnesswarningthreshold xxx; show tableskewnesswarningrows; set tableskewnesswarningrows xxx; 2.执行导入，使用INSERT或者COPY； 3.发现并处理告警，告警信息包括表名、最小行数、最大行数、总行数、平均行数、倾斜率，以及提示信息（检查数据分布或者修改参数）。 WARNING: Skewness occurs, table name: xxx, min value: xxx, max value: xxx, sum value: xxx, avg value: xxx, skew ratio: xxx HINT: Please check data distribution or modify warning threshold

本节主要介绍编辑同步任务 数据复制服务支持编辑实时同步任务的配置信息，包括源库信息、目标库信息。创建实例后，对于如下状态的任务，您可再次编辑并提交同步任务。 创建中 配置 前提条件 已登录数据复制服务控制台。 方式一 步骤 1 在“实时同步管理”页面的任务列表中，选择要修改的任务，单击操作列“编辑”按钮。 步骤 2 进入“源库及目标库”页面，填写源库和目标库信息，单击“下一步”。 步骤 3 在“设定同步”页面，选择编辑同步对象，单击“下一步”。 步骤 4 在“预检查”页面，进行同步任务预校验，校验是否可进行实时同步。 步骤 5 在“任务确认”页面，设置同步任务的启动时间，并确认同步任务信息无误后，单击“启动任务”，提交同步任务。 步骤 6 同步任务提交后，您可在“实时同步管理”页面，查看并管理自己的任务。 方式二 步骤 1 在“实时同步管理”界面，选择指定同步任务，单击任务名称。 步骤 2 单击“进入”，进入“源库及目标库”页面。 步骤 3 执行步骤2到步骤6。

本节主要介绍修改任务信息 灾备任务创建成功后，支持对部分任务信息进行修改，以方便区分和识别灾备任务。 支持可修改的任务信息如下： 任务名称 描述 任务启动时间 前提条件 已登录数据复制服务控制台。 操作步骤 步骤 1 在“实时灾备管理”页面，选择指定的灾备任务，单击任务名称。 步骤 2 进入“基本信息”页签，在“任务信息”模块下，选择需要修改的任务信息。 对于任务名称、描述，可以单击，进行修改。 单击，提交修改。 单击，取消修改。 表 实时灾备任务信息 任务信息 描述 任务名称 任务名称在450位之间，必须以字母开头，不区分大小写，可以包含字母、数字、中划线或下划线，不能包含其他的特殊字符。 描述 描述不能超过256位，且不能包含!<>&'"特殊字符。 对于任务启动时间，当灾备任务为“等待启动”状态时，才可以进行修改。 需要在“任务信息”模块下的“计划启动时间”处，单击“修改”，选择指定时间，单击“确定”即可。 步骤 3 修改完成后，可在“基本信息”页签下查看修改结果。

本节主要介绍查看迁移日志 迁移日志记录了数据迁移过程中的信息，包含告警、错误和提示等类型的信息。迁移过程中，可以通过查看迁移日志信息，帮助您分析系统中存在的问题。 前提条件 已登录数据复制服务控制台。 已成功创建迁移任务。 操作步骤 步骤 1 在“实时迁移管理”界面，选中指定迁移任务，单击任务名称。 步骤 2 在“迁移日志”页签，查看当前迁移任务的日志，可以根据“级别”筛选查看内容。 您可查看到日志对应的时间，级别和描述。

本节主要介绍查看灾备数据 灾备数据记录了灾备任务完成的记录，您可以通过该功能，了解灾备的完整性。 数据复制服务支持通过管理控制台查看灾备数据的初始化进度及数据健康报告。 前提条件 已登录数据复制服务管理控制台。 已成功创建数据灾备任务。 操作步骤 说明 任务列表中，仅展示当前登录用户所创建的全部任务，同一租户下的不同用户之间的任务不可见。 步骤 1 在“实时灾备管理”页面，选择指定的灾备任务，单击任务名称。 步骤 2 页面跳转至“基本信息”页签，单击“灾备数据”页签。 初始化进度 仅展示了初次创建灾备环境时，历史数据导入的进度信息，帮助用户了解灾备环境创建进度，完成历史数据导入后，意味着初始化已完成，该模块数据将不再更新。 数据健康报告 支持用户修改对比策略，周期性展示主实例与备实例的数据一致性对比结果，用于帮助用户审视灾备环境的数据健康情况。 只有灾备中的任务才会进行健康对比。 仅保留最近30次健康对比报告。 数据健康报告是为了用户定期且长期掌握主实例与备实例的数据一致性，为避免长期对比对主实例的性能损耗，对于特大表（比如超亿行的表）的对比，建议使用对比灾备项。 修改对比策略 修改对比策略不会影响当前进行的健康对比任务，修改后的设置在下次生效。 1、在“数据健康报告”页签的“健康对比策略”区域，单击“修改对比策略”，进入修改对比策略界面。 2、在“修改对比策略”界面设置各个参数。 开启状态：关闭健康对比策略后，下一次的健康对比将不会再进行，历史健康报告仍可正常查看。 对比频率：提供“每周对比”和“每天对比”两种对比频率。 对比时间：对比频率选择“每周对比”时，可设置周一到周日的一天或多天为对比时间。 时区：默认为本地时区。 生效时间：设置对比策略生效的时间段，建议设置在业务低峰期进行对比。生效时间内未完成健康对比会自动中断，已完成的对比结果仍可查看。 对比类型：默认为行对比+用户对比+对象对比。 3、单击“确定”，完成修改对比策略。 修改成功后，将在生效时间启动对比任务，您可以取消进行中的任务，取消后，已经对比成功的健康报告仍可查看。

本节主要介绍续传灾备任务 灾备过程中可能因外部因素导致灾备暂时故障，用户根据灾备日志信息解决问题后，可以通过续传功能继续灾备，常见场景如存储空间不足。 说明 如果因为非网络原因导致灾备失败，系统默认进行三次自动续传，若三次续传后仍无法恢复灾备，可手动进行续传。 如果因为网络原因导致灾备失败，系统自动续传，直到恢复灾备。 前提条件 已登录数据复制服务控制台。 已成功创建灾备任务，并且灾备失败。 方式一 在“实时灾备管理”页面任务列表中，选择需要启动的任务，单击操作列“续传”，重新提交灾备任务。 方式二 步骤 1 在“实时灾备管理”页面任务列表中，选择需要启动的任务，单击任务名称。 步骤 2 跳转至“基本信息”页签，切换至“灾备进度”页签，单击左上角“续传”，重新提交灾备任务。

本节主要介绍修改流速模式 流速模式支持限速和不限速，默认为不限速。DRS提供创建任务后修改流速模式，目前仅以下实时同步链路支持限速功能： 入云 MySQL>MySQL Oracle>MySQL Oracle>DRDS Oracle>PostgreSQL PostgreSQL>PostgreSQL 出云 MySQL>MySQL 自建自建 说明 限速模式只对全量同步阶段生效，增量同步阶段不生效。 增量阶段修改限速后，待任务再次进入全量阶段会生效。如增量中的任务修改限速，编辑任务新加同步对象后，限速会在同步任务的全量阶段生效。 前提条件 已登录数据复制服务控制台。 已创建同步任务。 方法一 步骤 1 在“基本信息”页签的“同步信息”区域，单击“流速模式”后的“修改”。 步骤 2 在弹出的对话框中修改流速模式。 方法二 步骤 1 在“实时同步管理”页面的同步列表中，选择需要修改流速模式的任务，单击操作列的“更多>限速”，或“限速”。 步骤 2 在弹出的对话框中修改流速模式。

本节主要介绍删除迁移任务 对于备份迁移任务，您可选择删除迁移任务。被删除后的任务将不会再出现在任务列表中，请谨慎操作。 前提条件 已登录数据复制服务控制台。 删除任务 步骤 1 在“备份迁移管理”页面的迁移列表中，选择需要删除的任务，单击操作列的“删除”按钮。 步骤 2 单击“确定”，提交删除任务。

本节主要介绍续传迁移任务 迁移中可能因外部因素导致迁移暂时故障，用户根据迁移日志信息解决问题后，可以通过续传功能继续迁移，常见场景如存储空间不足。 对于以下状态的任务，可以通过续传功能继续迁移任务。 迁移失败 已暂停 说明 如果因为非网络原因导致迁移失败，系统默认进行三次自动续传，若三次续传后仍无法恢复，可手动进行续传。 前提条件 已登录数据复制服务控制台。 已成功创建迁移任务，并且迁移失败。 方式一 在“实时迁移管理”页面任务列表中，选择需要启动的任务，单击操作列“续传”，重新提交迁移任务。 方式二 步骤 1 在“实时迁移管理”页面任务列表中，选择需要启动的任务，单击任务名称。 步骤 2 跳转至“基本信息”页签，切换至“迁移进度”页签，单击左上角“续传”，重新提交迁移任务。

本节主要介绍查看灾备日志 灾备日志记录了数据灾备同步过程中的信息，包含告警、错误和提示等类型的信息。数据灾备过程中，可以通过查看灾备日志信息，帮助您分析系统中存在的问题。 前提条件 已登录数据复制服务控制台。 操作步骤 步骤 1 在“实时灾备管理”界面，选中指定灾备任务，单击任务名称。 步骤 2 在“灾备日志”页签，查看当前灾备任务的日志。

本节主要介绍删除同步任务 对于已结束或者配置失败的实时同步任务，您可选择删除同步任务。被删除后的任务将不会再出现在任务列表中，请谨慎操作。 前提条件 已登录数据复制服务控制台。 删除任务 步骤 1 在“实时同步管理”页面的任务列表中，选择要删除的任务，单击“删除”。 步骤 2 单击“确定”，提交删除任务。

本节主要介绍续传同步任务 实时同步中可能因外部因素导致同步暂时故障，用户根据同步日志信息解决问题后，可以通过续传功能继续同步，常见场景如存储空间不足。 对于以下状态的任务，可以通过续传功能继续同步任务。 同步失败 已暂停 说明 如果因为非网络原因导致同步失败，系统默认进行三次自动续传，若三次续传后仍无法恢复，可手动进行续传。 如果因为网络原因导致同步失败，系统自动续传，直到恢复同步。 前提条件 已登录数据复制服务控制台。 方式一 在“实时同步管理”页面任务列表中，选择需要启动的任务，单击操作列“续传”，重新提交同步任务。 方式二 步骤 1 在“实时同步管理”页面任务列表中，选择需要启动的任务，单击任务名称。 步骤 2 跳转至“基本信息”页签，切换至“同步进度”页签，单击左上角“续传”，重新提交同步任务。 批量续传 步骤 1 在“实时同步管理”页面的同步任务列表中，选择需要续传的任务。 步骤 2 单击左上方的“批量操作”，选择“批量续传”。 步骤 3 在弹出的确认对话框中，确认任务信息后，单击“是”，提交续传任务。

本节主要介绍暂停迁移任务 迁移时不可避免业务高峰期的情况下，如果流速模式仍不能满足需要，DRS提供对迁移中的任务进行暂停功能。 目前以下迁移链路支持暂停功能： 入云 MySQL>MySQL MongoDB>DDS 出云 MySQL>MySQL DDS>MongoDB 前提条件 已登录数据复制服务控制台。 迁移任务正常运行中。 暂停任务 步骤 1 在“实时迁移管理”页面的迁移列表中，选择要暂停的迁移任务，单击“操作 > 暂停”。 步骤 2 在弹出的“暂停任务”对话框中，选择“暂停日志抓取”后，单击“是”。 说明 暂停成功后，状态栏显示为“已暂停”。 勾选“暂停日志抓取”后，该功能会停止一切DRS和源库、目标库的连接，请注意暂停过长可能会因为源端所需日志过期而导致任务无法恢复续传。建议暂停时间不超过24小时。 需要继续迁移时，可以使用续传功能。

本章节主要介绍 SQL语法类 DRDS是否支持分布式JOIN DRDS支持分布式JOIN。 表设计时，增加字段冗余 支持跨分片的JOIN，主要实现的方式有三种：广播表，ER分片和ShareJoin。 DRDS目前禁止多个表的跨库update和delete。 如何进行SQL优化 尽量避免使用LEFT JOIN或RIGHT JOIN，建议使用INNER。 在使用LEFT或RIGHT JOIN时，ON会优先执行，WHERE条件在最后执行，所以在使用过程中，条件尽可能在ON语句中判断，减少WHERE的执行。 尽量少用子查询，改用JOIN，避免大表全表扫描。 DRDS是否支持数据类型强制转换 数据类型转换属于高级用法。DRDS对SQL的兼容性会逐步完善，如有需要请提工单处理。

本节主要介绍产品规格 通用增强型实例是新推出的一系列性能高、计算能力稳定的实例规格，搭载英特尔®至强®可扩展处理器，配套高性能网络，综合性能及稳定性全面提升，满足对业务稳定性及计算性能要求较高的企业级应用诉求。 产品规格 规格类型 架构 CPU（核） 内存（GB） :::: 通用增强型 X86 8 16 通用增强型 X86 16 32 通用增强型 X86 32 64

本章节介绍一致性备份说明 DRDS对一致性备份进行了功能优化调整，将该功能调整成恢复数据中的“Metadata恢复”。调整为“Metadata恢复”之后，已经创建的一致性备份将不可再用于恢复，一致性备份相关操作将会隐藏。如果您需要进行数据恢复，请通过“Metadata恢复”完成。

本节主要介绍恢复configsvr副本集 准备目录 rm rf /compile/clusterrestore/cfg mkdir p /compile/clusterrestore/cfg1/data/db mkdir p /compile/clusterrestore/cfg1/log mkdir p /compile/clusterrestore/cfg2/data/db mkdir p /compile/clusterrestore/cfg2/log mkdir p /compile/clusterrestore/cfg3/data/db mkdir p /compile/clusterrestore/cfg3/log 操作步骤 步骤 1 准备单节点配置文件和数据目录，以单节点方式启动进程。 配置文件如下（restoreconfig/single40303.yaml）。 net: bindIp: 127.0.0.1 port: 40303 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/cfg1/configsvr.pid} storage: dbPath: /compile/clusterrestore/cfg1/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/cfg1/log/configsingle.log} 准备数据，将解压后的configsvr文件拷贝到单节点dbPath目录下。 cp aR /compile/download/backups/cac1efc8e65e42ecad8953352321bfeein0241c8a32fb10245899708dea453a8c5c9no02/ /compile/clusterrestore/cfg1/data/db/ 启动进程。 ./mongod f restoreconfig/single40303.yaml 步骤 2 连接单节点，执行配置命令。 连接命令：./mongo host 127.0.0.1 port 40303 执行如下命令，修改副本集配置信息。 var cfdb.getSiblingDB('local').system.replset.findOne(); cf['members'][0]['host']'127.0.0.1:40303'; cf['members'][1]['host']'127.0.0.1:40304'; cf['members'][2]['host']'127.0.0.1:40305'; cf['members'][0]['hidden']false; cf['members'][1]['hidden']false; cf['members'][2]['hidden']false; cf['members'][0]['priority']1; cf['members'][1]['priority']1; cf['members'][2]['priority']1; db.getSiblingDB('local').system.replset.remove({}); db.getSiblingDB('local').system.replset.insert(cf) 执行如下命令，清理内置账号。 db.getSiblingDB('admin').dropAllUsers(); db.getSiblingDB('admin').dropAllRoles(); 执行如下命令，更新mongos和shard信息。 db.getSiblingDB('config').mongos.remove({}); 先查询config.shards表中的多个shard的id信息，用于下面语句的id的查询条件。逐个更新每条记录。 db.getSiblingDB('config').shards.update({'id' : 'shard1'},{$set: {'host': 'shard1/127.0.0.1:40306,127.0.0.1:40307,127.0.0.1:40308'}}) db.getSiblingDB('config').shards.update({'id' : 'shard2'},{$set: {'host': 'shard2/127.0.0.1:40309,127.0.0.1:40310,127.0.0.1:40311'}}) db.getSiblingDB('config').mongos.find({}); db.getSiblingDB('config').shards.find({}); 执行如下命令，关闭单节点进程。 db.getSiblingDB('admin').shutdownServer(); 步骤 3 搭建configsvr副本集。 准备副本集配置文件和目录，将configsvr1节点的dbPath文件拷贝到其他两个节点目录下。 cp aR /compile/clusterrestore/cfg1/data/db/ /compile/clusterrestore/cfg2/data/db/ cp aR /compile/clusterrestore/cfg1/data/db/ /compile/clusterrestore/cfg3/data/db/ 修改configsvr1节点配置文件，增加副本集配置属性（restoreconfig/configsvr40303.yaml）。 net: bindIp: 127.0.0.1 port: 40303 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/cfg1/configsvr.pid} replication: {replSetName: config} sharding: {archiveMovedChunks: false, clusterRole: configsvr} storage: dbPath: /compile/clusterrestore/cfg1/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/cfg1/log/configsvr.log} 启动进程。 ./mongod f restoreconfig/configsvr40303.yaml 修改configsvr2节点配置文件，增加副本集配置属性（restoreconfig/configsvr40304.yaml）。 net: bindIp: 127.0.0.1 port: 40304 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/cfg2/configsvr.pid} replication: {replSetName: config} sharding: {archiveMovedChunks: false, clusterRole: configsvr} storage: dbPath: /compile/clusterrestore/cfg2/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/cfg2/log/configsvr.log} 启动进程 ./mongod f restoreconfig/configsvr40304.yaml 修改configsvr3节点配置文件，增加副本集配置属性（restoreconfig/configsvr40305.yaml）。 net: bindIp: 127.0.0.1 port: 40304 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/cfg2/configsvr.pid} replication: {replSetName: config} sharding: {archiveMovedChunks: false, clusterRole: configsvr} storage: dbPath: /compile/clusterrestore/cfg2/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/cfg2/log/configsvr.log} 启动进程。 ./mongod f restoreconfig/configsvr40305.yaml 步骤 4 等待选主成功。 ./mongo host 127.0.0.1 port 40303 执行命令rs.status()，查看是否已存在主节点Primary。

本文主要介绍恢复mongos节点 步骤 1 准备mongos节点的配置文件和目录。 rm rf /compile/clusterrestore/mgs mkdir p /compile/clusterrestore/mgs1/log mkdir p /compile/clusterrestore/mgs2/log 步骤 2 配置文件（restoreconfig/mongos40301.yaml）。 net: bindIp: 127.0.0.1 port: 40301 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/mgs1/mongos.pid} sharding: {configDB: 'config/127.0.0.1:40303,127.0.0.1:40304,127.0.0.1:40305'} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/mgs1/log/mongos.log} 步骤 3 配置文件（restoreconfig/mongos40302.yaml）。 net: bindIp: 127.0.0.1 port: 40302 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/mgs2/mongos.pid} sharding: {configDB: 'config/127.0.0.1:40303,127.0.0.1:40304,127.0.0.1:40305'} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/mgs2/log/mongos.log} 步骤 4 启动mongo节点。 ./mongos f restoreconfig/mongos40301.yaml ./mongos f restoreconfig/mongos40302.yaml

本节介绍如何在云审计服务管理控制台查看最近7天的操作记录。 在您开通了云审计服务后，系统开始记录云服务资源的操作。云审计服务管理控制台保存最近7天的操作记录。 操作步骤 步骤 1 登录管理控制台。 步骤 2 单击管理控制台左上角的，选择区域和项目。 步骤 3 单击“服务列表”，选择“管理与部署 > 云审计服务”，进入云审计服务信息页面。 步骤 4 在左侧导航树，单击“事件列表”，进入事件列表信息页面。 步骤 5 事件列表支持通过筛选来查询对应的操作事件。当前事件列表支持四个维度的组合查询，详细信息如下： 事件来源、资源类型和筛选类型。 在下拉框中选择查询条件。 其中，筛选类型选择“按事件名称”时，还需选择某个具体的事件名称。 选择“按资源ID”时，还需选择或者手动输入某个具体的资源ID。 选择“按资源名称”时，还需选择或手动输入某个具体的资源名称。 操作用户：在下拉框中选择某一具体的操作用户，此操作用户指用户级别，而非租户级别。 事件级别：可选项为“所有事件级别”、“normal”、“warning”、“incident”，只可选择其中一项。 起始时间、结束时间：可通过选择时间段查询操作事件。 步骤 6 在需要查看的记录左侧，单击展开该记录的详细信息。 步骤 7 在需要查看的记录右侧，单击“查看事件”，在弹出框中显示该操作事件结构的详细信息。

恢复步骤 命令运行目录：/compile/mongodb/mongodbsrc4.0.3

本文主要介绍计费类问题 在哪里查询不同规格实例的价格？ 不同区域、不同规格的实例价格有所差异，您可以在产品价格详情查询价格 预付费和后付费是什么意思？如何选择？ 预付费：一般为包年包月的购买形式，先购买再使用，系统根据用户选择的规格计算购买金额，对用户帐户金额进行扣除。

本文主要介绍通过云日志服务查看审计日志 通过云日志服务进行分析日志、搜索日志、日志可视化、下载日志和查看实时日志等操作。 查看LTS审计日志 说明 实例已经配置了访问日志，操作详情请参见日志配置管理—新增 步骤 1 在页面左上角单击，选择“管理与监管 > 云日志服务”，进入云服务日志页面。 步骤 2 在“日志组列表”区域，选择目标日志组，单击日志组名称。 查看日志详情 下载LTS日志文件 说明 如果实例已经配置了访问日志，操作详情请参见 步骤 1 在页面左上角单击，选择“管理与监管 > 云日志服务”，进入云服务日志页面。 步骤 2 在“日志组列表”区域，选择目标日志组，单击日志组名称。 下载日志 步骤 3 单击“”。

本节主要介绍恢复shardsvr2副本集 准备目录 rm rf /compile/clusterrestore/shd2 mkdir p /compile/clusterrestore/shd21/data/db mkdir p /compile/clusterrestore/shd21/log mkdir p /compile/clusterrestore/shd22/data/db mkdir p /compile/clusterrestore/shd22/log mkdir p /compile/clusterrestore/shd23/data/db mkdir p /compile/clusterrestore/shd23/log 操作步骤 步骤 1 准备单节点配置文件和目录，以单节点方式启动进程。 配置文件如下（restoreconfig/single40309.yaml）。 net: bindIp: 127.0.0.1 port: 40309 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/shd21/mongod.pid} storage: dbPath: /compile/clusterrestore/shd21/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/shd21/log/mongod.log} 准备数据，将解压后的shardsvr2文件拷贝到单节点dbPath目录下。 cp aR /compile/download/backups/cac1efc8e65e42ecad8953352321bfeein0292b196d2401041a7af869a2a3cab7079no02/ /compile/clusterrestore/shd21/data/db/ 启动进程。 ./mongod f restoreconfig/single40309.yaml 步骤 2 连接单节点，执行配置命令。 连接命令：./mongo host 127.0.0.1 port 40309 执行如下命令，修改副本集配置信息。 var cfdb.getSiblingDB('local').system.replset.findOne(); cf['members'][0]['host']'127.0.0.1:40309'; cf['members'][1]['host']'127.0.0.1:40310'; cf['members'][2]['host']'127.0.0.1:40311'; cf['members'][0]['hidden']false; cf['members'][1]['hidden']false; cf['members'][2]['hidden']false; cf['members'][0]['priority']1; cf['members'][1]['priority']1; cf['members'][2]['priority']1; db.getSiblingDB('local').system.replset.remove({}); db.getSiblingDB('local').system.replset.insert(cf) 执行如下命令，清理内置账号。 db.getSiblingDB('admin').dropAllUsers(); db.getSiblingDB('admin').dropAllRoles(); 执行如下命令，更新configsvr信息。 var vs db.getSiblingDB('admin').system.version.find(); while (vs.hasNext()) { var curr vs.next(); if (curr.hasOwnProperty('configsvrConnectionString')) { db.getSiblingDB('admin').system.version.update({'id' : curr.id}, {$set: {'configsvrConnectionString': 'config/127.0.0.1:40303,127.0.0.1:40304,127.0.0.1:40305'}}); } } 执行如下命令，关闭单节点进程。 db.getSiblingDB('admin').shutdownServer(); 步骤 3 搭建shardsvr2副本集。 准备副本集配置文件和目录，将shardsvr2节点的dbPath文件拷贝到其他两个节点目录下。 cp aR /compile/clusterrestore/shd21/data/db/ /compile/clusterrestore/shd22/data/db/ cp aR /compile/clusterrestore/shd21/data/db/ /compile/clusterrestore/shd23/data/db/ 修改shardsvr21节点配置文件，增加副本集配置属性（restoreconfig/shardsvr40309.yaml）。 replication.replSetName 的值，参考该章节中的shard的id信息。 net: bindIp: 127.0.0.1 port: 40309 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/shd21/mongod.pid} replication: {replSetName: shard2} sharding: {archiveMovedChunks: false, clusterRole: shardsvr} storage: dbPath: /compile/clusterrestore/shd21/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/shd21/log/mongod.log} 启动进程。 ./mongod f restoreconfig/shardsvr40309.yaml 修改shardsvr22节点配置文件，增加副本集配置属性（restoreconfig/shardsvr40310.yaml）。 replication.replSetName 的值，参考该章节中的shard的id信息。 net: bindIp: 127.0.0.1 port: 40310 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/shd22/mongod.pid} replication: {replSetName: shard2} sharding: {archiveMovedChunks: false, clusterRole: shardsvr} storage: dbPath: /compile/clusterrestore/shd22/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/shd22/log/mongod.log} 启动进程。 ./mongod f restoreconfig/shardsvr40310.yaml 修改shardsvr23节点配置文件，增加副本集配置属性（restoreconfig/shardsvr40311.yaml）。 replication.replSetName 的值，参考该章节中的shard的id信息。 net: bindIp: 127.0.0.1 port: 40311 unixDomainSocket: {enabled: false} processManagement: {fork: true, pidFilePath: /compile/clusterrestore/shd23/mongod.pid} replication: {replSetName: shard2} sharding: {archiveMovedChunks: false, clusterRole: shardsvr} storage: dbPath: /compile/clusterrestore/shd23/data/db/ directoryPerDB: true engine: wiredTiger wiredTiger: collectionConfig: {blockCompressor: snappy} engineConfig: {directoryForIndexes: true, journalCompressor: snappy} indexConfig: {prefixCompression: true} systemLog: {destination: file, logAppend: true, logRotate: reopen, path: /compile/clusterrestore/shd23/log/mongod.log} 启动进程。 ./mongod f restoreconfig/shardsvr40311.yaml 步骤 4 等待选主成功。 ./mongo host 127.0.0.1 port 40309 执行命令rs.status()，查看是否已存在主节点Primary。

本文介绍DDS集群架构的组成。 DDS集群由mongos、config、shard组成，节点架构示意图如下： 图 分片集群示意图 mongos mongos负责查询与数据写入的路由，是实例访问的统一入口。 每个实例有2～32个mongos，数量由用户自定义。 用户可直接连接mongos，mongos从config读取配置信息，将读写请求分发到shard。 config config负责存储实例的配置信息，由1个副本集组成。 config可用是部署一个实例或者修改实例元信息的前提。 用户不能直接连接config。 shard 集群实例的shard，负责存储用户的数据。 每个集群实例有2～32个shard，数量由用户自定义。 每个shard由1个副本集组成，副本集为每个shard的数据提供了冗余和高可靠性。 用户不能直接连接shard。

本章节会介绍如何修改系统权重分配规则 开通读写分离功能后，本文介绍各种规格的实例默认的读权重分配规则。 系统权重分配规则 系统自动设置实例的读权重时，权重值是固定的，如下表所示： 说明 默认权重值CPU个数50。权重值范围为100~1000。 通过Hint指定SQL发往主实例或只读实例 在SQL开头添加hint注释进行强制路由； /FORCEMASTER/强制路由到主节点； /FORCESLAVE/强制路由到只读节点； 说明 在读写分离权重分配体系之外，Hint可作为另外一种SQL补充语法来指定相关SQL到主实例或只读实例执行。 Hint注释仅作为路由建议，非只读SQL、事务中的场景不能强制路由到只读节点。