galife

MongoDB のレプリカセットで特定メンバーをプライマリに昇格させる方法

今回は「MongoDBの特定レプリカセットメンバーを強制的にプライマリサーバーにする方法」についてまとめます。

前提状況
優先度の調整で変更する
コマンドで変更する

前提状況

今回は以下のような状況（ _id: 1 がプライマリ、 _id: 0 および _id: 2 はセカンダリ）で、 _id: 0 をプライマリにする方法を見ていきます。

変更する方法は以下の2通りが考えられます。

優先度の調整で変更する
コマンドで変更する

「優先度調整」は設定変更なので、サーバースペックが異なるなど恒久的にあるサーバーを優先的にプライマリサーバーとしたい場合に有効な手段になります。「コマンド」は一時的な変更なので動作確認やテストなどの用途での利用になるかと思います。

優先度の調整で変更する

mongoシェルコマンドの rs.config() および rs.reconfig() を利用して優先度を変更することで特定メンバーをプライマリに昇格させます。設定変更なので一度実行すると基本的に特定サーバーがプライマリサーバーに昇格するようになります。例えば、一度ダウンしてレプリカセットから外れた後、再び復活してレプリカセットへ参加した際にセカンダリとして参加してすぐプライマリへ昇格する動作を行います。

プライマリサーバーへ接続

rs.reconfig() はプライマリサーバー上でしか実行できないので、プライマリサーバーへ接続します。
```
mongo --host 127.0.0.1:8002
```
現在の設定を取得
```
PRIMARY> config = rs.config()
```

設定値を修正

PRIMARY> config.members[0].priority = 2
PRIMARY> config.members[1].priority = 1
PRIMARY> config.members[2].priority = 1

修正した設定値を適用
```
PRIMARY> rs.reconfig(config)
```
一度 mongoシェル接続を切断
```
PRIMARY> exit
```
10秒程度待って(プライマリサーバーの変更処理が終わるのを待って)任意のサーバーへ接続
```
mongo --host 127.0.0.1:8001
```

変更結果を確認

PRIMARY> rs.status()
{
  ...
  "members" : [
    {
      "_id" : 0,
      "name" : "127.0.0.1:8001",
      "health" : 1,
      "state" : 1,
      "stateStr" : "PRIMARY",
      ...
    },
    {
      "_id" : 1,
      "name" : "127.0.0.1:8002",
      "health" : 1,
      "state" : 2,
      "stateStr" : "SECONDARY",
      ...
    },
    {
      "_id" : 2,
      "name" : "127.0.0.1:8003",
      "health" : 1,
      "state" : 2,
      "stateStr" : "SECONDARY",
      ...
    }
  ],
  ...
}

コマンドで変更する

mongoシェルコマンドの rs.freeze() および rs.stepDown() を利用して変更することができます。コマンドそれぞれの動作概略は以下の通りです。

rs.freeze()
指定された時間（秒）の間、プライマリに昇格しなくなります。
rs.stepDown()
指定された時間（秒）の間、セカンダリに降格して次のプライマリサーバー選出を行います。

以下では実際に上記コマンドを利用してプライマリサーバーに変更する手順を載せます。

プライマリにしたくないサーバーへ接続
```
mongo --host 127.0.0.1:8003
```
rs.freeze() を実行してプライマリ昇格を抑止
```
SECONDARY> rs.freeze(120)
```
mongoシェル接続を切断
```
SECONDARY> exit
```
現在のプライマリサーバーへ接続
```
mongo --host 127.0.0.1:8002
```
rs.stepDown() を実行してセカンダリに降格
```
PRIMARY> rs.stepDown(120)
```
一度 mongoシェル接続を切断
```
PRIMARY> exit
```
10秒程度待って(プライマリサーバーの変更処理が終わるのを待って)任意のサーバーへ接続
```
mongo --host 127.0.0.1:8001
```

変更結果を確認

PRIMARY> rs.status()
{
  ...
  "members" : [
    {
      "_id" : 0,
      "name" : "127.0.0.1:8001",
      "health" : 1,
      "state" : 1,
      "stateStr" : "PRIMARY",
      ...
    },
    {
      "_id" : 1,
      "name" : "127.0.0.1:8002",
      "health" : 1,
      "state" : 2,
      "stateStr" : "SECONDARY",
      ...
    },
    {
      "_id" : 2,
      "name" : "127.0.0.1:8003",
      "health" : 1,
      "state" : 2,
      "stateStr" : "SECONDARY",
      ...
    }
  ],
  ...
}

今回は「MongoDBの特定レプリカセットメンバーを強制的にプライマリサーバーにする方法」についてまとめました。ポイントは以下の通りです。

優先度変更は恒久的な対応
コマンド変更は一時的な対応

参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

MongoDB の oplog ファイルサイズを変更する方法

今回は「MongoDB の oplog ファイルサイズを変更する方法」についてまとめます。

概要
変更手順

概要

oplogファイルサイズの変更は replSetResizeOplog コマンドで変更できます。

基本的には現状確認、検討、変更、データ再同期の手順です。実施する際はセカンダリサーバーから実施するようにします。データ再同期はサイズ縮小する場合だけですが、サーバー停止を伴うので実施には要注意です。

それでは以下で詳しい手順を見ていきます。

変更手順

現在のサイズを確認

現在の設定を確認してどの程度に変更するかを考えます。

レプリカセットのセカンダリサーバーへ接続
```
mongo --host 127.0.0.1:8002
```

rs.printReplicationInfo()コマンドでoplogサイズ確認

レプリケーションに関する情報を取得、oplogサイズを確認します。

SECONDARY> rs.printReplicationInfo()

以下のような応答が返ってきますので、 oplog size を確認します。

configured oplog size:   2244.146240234375MB
log length start to end: 9152215secs (2542.28hrs)
oplog first event time:  Sat Mar 03 2018 23:42:09 GMT+0900
oplog last event time:   Sun Jun 17 2018 21:59:04 GMT+0900
now:                     Sun Jun 17 2018 21:59:11 GMT+0900

oplogサイズ変更

レプリカセットのセカンダリサーバーへ接続
```
mongo --host 127.0.0.1:8002
```
replSetResizeOplogコマンドでoplogサイズ変更

サイズはメガバイトで指定します。以下のサンプルコードでは16G (= 16000MB) に設定しています。
```
SECONDARY> db.adminCommand({ replSetResizeOplog: 1, size: 16000 })
```
上記を繰り返しすべてのサーバーのoplogサイズを変更

データ再同期

oplogサイズを小さくする場合、データ不整合が発生する可能性があるためデータ再同期させる必要があります。

データ再同期したい稼働中のサーバーを停止

mongoシェルコマンドで以下を実行することで安全に停止させます。
```
SECONDARY> use admin
SECONDARY> db.shutdownServer()
```
dbPath配下のフォルダ・ファイルをすべて削除

コマンドプロンプト上で以下のコマンドを実行し、dbPath配下のファイルやフォルダをすべて削除します。
```
set DBPATH=C:\mongodb\server2\data
del "%DBPATH%" /f /s /q
for /d %a in (%DBPATH%\*) do (rmdir /s /q "%a")
```

mongod を起動

mongo --config "C:\mongodb\server2\mongod.server2.cfg"

今回は「MongoDB の oplog ファイルサイズを変更する方法」についてまとめました。ポイントは以下の通りです。

oplogファイルサイズ変更は db.adminCommand({ replSetResizeOplog: 1, size: 16000 }) で実行可能。
セカンダリサーバーから順に変更する。
oplogファイルサイズを小さくする場合はデータ再同期が必要。

参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

参考記事

MongoDB - Change the Size of the Oplog

MongoDB のレプリカセットへ Node.jsドライバーを使ってアクセスする方法

今回は「MongoDB のレプリカセットにNode.jsドライバを使ってアクセスする方法」についてまとめます。

接続する
読み書きする

接続する

MongoDBのレプリカセットも接続さえできてしまえばほぼ終わりです。ここではその基本となる接続文字列、読み込み設定、書き込み設定についてまとめます。

Node.jsドライバーでMongoDBへ接続する場合、 MongoClient.connect() を利用するので、その引数にどのような値を与えるとよいか、が要です。

接続文字列 (url)

ここでは MongoClient.connect() の第1引数に指定する接続文字列の設定方法についてみていきます。

MongoDBの接続文字列は以下のような構成になっています。

mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]

基本は host1, host2, ... というように接続先ホスト名を列挙して指定します。また、 options としてレプリカセット ?replicaSet=<レプリカセット名> を指定します。もし、レプリカセットが認証を有効にしているのであれば username 、 password および database を指定します。

例えば、レプリカセットメンバーが 127.0.0.1:8001 、 127.0.0.1:8002 、 127.0.0.1:8003 で、レプリカセット名が rs0 、認証が有効でユーザー名/パスワードが test/test で、認証先データベースが test 出会った場合、以下のようなURLになります。

mongodb://test:test@127.0.0.1:8001,127.0.0.1:8002,127.0.0.1:8003/test?replicaSet=rs0

読み込み設定 (options)

MongoClient.connect() の第2引数 options のうち、レプリカセットの読み込みに関するオプションを見ていきます。関係するのは readPreference の1つのみです。

readPreference

Read Preference 設定では、どのサーバーから優先的にデータ読み込みするかを設定します。設定できる値は以下のような5種類です。

設定値	説明
PRIMARY	デフォルトモード。プライマリサーバーから取得します。
PRIMARY_PREFERRED	ほとんどの場合はプライマリサーバーから取得しますが、プライマリサーバーにアクセスできない場合はセカンダリサーバーから取得します。
SECONDARY	セカンダリサーバーから取得します。
SECONDARY_PREFERRED	ほとんどの場合はセカンダリサーバーから取得しますが、セカンダリサーバーにアクセスできない場合はプライマリサーバーから取得します。
NEAREST	レプリカセットの種類に関わらず、レイテンシーが最小のサーバーから取得します。

書き込み設定

MongoClient.connect() の第2引数 options のうち、レプリカセットの書き込みに関するオプションを見ていきます。関係するのは w 、 j 、 wtimeoutの3つです。

w オプションでは何台目まで書き込みを保証するかを設定します。

設定値	説明
<number>	指定した台数まで書き込まれることを保証します。
"majority"	投票権のあるサーバーの過半数に書き込まれることを保証します。

ジャーナルへの書き込みまで保証するかどうかを設定します。

設定値	説明
true	ディスクへの書き込みまで行います。
false	デフォルト。メモリ上への書き込みのみを保証します。

wtimeout

書き込み応答のタイムアウト設定です。指定した時間内に応答がなければ書き込み失敗と判断して後続の処理を続けられるようにします。

設定値	説明
<number>	書き込みをタイムアウトにする時間（ミリ秒）を指定します。設定する場合は1より大きな値を指定します。 0を指定した場合、タイムアウト処理を行いません。

読み書きする

実際に上記設定を用いてレプリカセットへ書き込みを行うコードを載せます。タイトルは「読み書き」と書いていますが接続できれば関係ないのでここでは「書き込み」のサンプルコードを掲載します。

index.js

var { MongoClient, ReadPreference } = require("mongodb");

var usr = "test";
var pwd = "test";
var authDb = "test";
var hosts = [
  "127.0.0.1:8001",
  "127.0.0.1:8002",
  "127.0.0.1:8003"
];
var URL = `mongodb://${usr}:${pwd}@${hosts.join(",")}/${authDb}?replicaSet=rs0`;

var options = {
  w: "majority",
  wtimeout: 3000,
  j: true,
  readPreference: ReadPreference.NEAREST
};

MongoClient.connect(URL, options, (err, client) => {
  if (err) {
    console.log(err);
    return;
  }
  var db = client.db("test");
  db.collection("orders").insertMany([
    { datetime: "2018-01-12", item: "apple", quantity: 8 },
    { datetime: "2018-01-12", item: "grapefruit", quantity: 3 },
    { datetime: "2018-01-13", item: "strawberry", quantity: 4 },
    { datetime: "2018-01-14", item: "orange", quantity: 8 },
    { datetime: "2018-01-15", item: "apple", quantity: 6 },
    { datetime: "2018-01-15", item: "grapefruit", quantity: 5 },
    { datetime: "2018-01-17", item: "pear", quantity: 2 },
    { datetime: "2018-01-17", item: "apple", quantity: 9 },
    { datetime: "2018-01-20", item: "orange", quantity: 10 },
    { datetime: "2018-01-21", item: "strawberry", quantity: 2 },
    { datetime: "2018-01-21", item: "banana", quantity: 3 },
    { datetime: "2018-01-22", item: "strawberry", quantity: 2 }
  ]).then((docs) => {
    console.log(docs);
  }).catch((err) => {
    console.log(err);
  }).then(() => {
    client.close();
  });
});

今回は「MongoDB のレプリカセットにNode.jsドライバを使ってアクセスする方法」についてまとめました。ポイントは以下の通りです。

接続先ホストは列挙する
MongoClient.connect() で接続設定

参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

参考記事

MongoDB - Connection String URI Format

MongoDB のレプリカセットへ mongoシェルを使ってアクセスする方法

今回は「MongoDB のレプリカセットにmongoシェルを使ってアクセスする方法」についてまとめます。

接続する
読み書きする
- プライマリサーバーで読み書き
- セカンダリサーバーで読取

接続する

何はともあれサーバーへの接続から見ていきます。

サーバーを指定して接続する

もっとも単純な接続は接続先サーバーを指定した接続で、サーバーIPが 127.0.0.1:8001 であれば以下のようなコマンドで接続できます。

C:\work>mongo --host 127.0.0.1:8001

単一ノードの場合と基本的に接続方法は変わりません。接続できれば接続先サーバーが PRIMARY か SECONDARY かなどがわかる表記があります。

MongoDB shell version v3.6.2
connecting to: mongodb://127.0.0.1:8001/
MongoDB server version: 3.6.2
MongoDB Enterprise rs0:PRIMARY>

プライマリサーバーを探す

レプリカセットで書き込みができるのは唯一プライマリサーバーのみなので、書き込みたい場合はプライマリサーバーを探す必要があります。

任意のサーバーへ接続したのち、 rs.status() を実行すると接続中レプリカセットの各メンバーステータスを確認できます。

PRIMARY> rs.status()

上記コマンドを実行すると以下のような応答を取得できます。 stateStr に各サーバーがどの状態で稼働しているかが記載されているので、この中からプライマリを探します。

{
  "set" : "rs0",
  "date" : ISODate("2018-02-27T05:13:26.672Z"),
  "myState" : 1,
  "term" : NumberLong(18),
  "heartbeatIntervalMillis" : NumberLong(2000),
  "optimes" : {
    "lastCommittedOpTime" : {
      "ts" : Timestamp(1519708406, 1),
      "t" : NumberLong(18)
    },
    "readConcernMajorityOpTime" : {
      "ts" : Timestamp(1519708406, 1),
      "t" : NumberLong(18)
    },
    "appliedOpTime" : {
      "ts" : Timestamp(1519708406, 1),
      "t" : NumberLong(18)
    },
    "durableOpTime" : {
      "ts" : Timestamp(1519708406, 1),
      "t" : NumberLong(18)
    }
  },
  "members" : [
    {
      "_id" : 0,
      "name" : "127.0.0.1:8001",
      "health" : 1,
      "state" : 1,
      "stateStr" : "PRIMARY",
      "uptime" : 144787,
      "optime" : {
        "ts" : Timestamp(1519708406, 1),
        "t" : NumberLong(18)
      },
      "optimeDate" : ISODate("2018-02-27T05:13:26Z"),
      "electionTime" : Timestamp(1519563637, 1),
      "electionDate" : ISODate("2018-02-25T13:00:37Z"),
      "configVersion" : 7,
      "self" : true
    },
    {
      "_id" : 1,
      "name" : "127.0.0.1:8002",
      "health" : 1,
      "state" : 2,
      "stateStr" : "SECONDARY",
      "uptime" : 144759,
      "optime" : {
        "ts" : Timestamp(1519708406, 1),
        "t" : NumberLong(18)
      },
      "optimeDurable" : {
        "ts" : Timestamp(1519708406, 1),
        "t" : NumberLong(18)
      },
      "optimeDate" : ISODate("2018-02-27T05:13:26Z"),
      "optimeDurableDate" : ISODate("2018-02-27T05:13:26Z"),
      "lastHeartbeat" : ISODate("2018-02-27T05:13:26.413Z"),
      "lastHeartbeatRecv" : ISODate("2018-02-27T05:13:25.208Z"),
      "pingMs" : NumberLong(0),
      "syncingTo" : "127.0.0.1:8001",
      "configVersion" : 7
    },
    {
      "_id" : 2,
      "name" : "127.0.0.1:8003",
      "health" : 1,
      "state" : 7,
      "stateStr" : "ARBITER",
      "uptime" : 144780,
      "lastHeartbeat" : ISODate("2018-02-27T05:13:26.431Z"),
      "lastHeartbeatRecv" : ISODate("2018-02-27T05:13:22.188Z"),
      "pingMs" : NumberLong(0),
      "configVersion" : 7
    }
  ],
  "ok" : 1,
  "operationTime" : Timestamp(1519708406, 1),
  "$clusterTime" : {
    "clusterTime" : Timestamp(1519708406, 1),
    "signature" : {
      "hash" : BinData(0,"0vruFBe4bYLFcuHiqSa9gtgUhRo="),
      "keyId" : NumberLong("6518666083560325121")
    }
  }
}

ユーザー名とパスワードを指定して接続する

レプリカセットがアクセス制御を有効化している場合、ユーザー名とパスワードおよび認証先データベースを指定して接続する必要があります。認証の仕方は2通りあり、「接続時にユーザー名とパスワードを指定する方法」と「接続後にユーザー名とパスワードを指定する方法」があります。

例えば、ユーザー名「user」、パスワード「password」、認証先データベース「test」でサーバー「127.0.0.1:8001」へ接続する場合、それぞれどのように接続するか見ていきます。

接続時にユーザー名とパスワードを指定する方法

接続時にユーザー名、パスワード、認証情報を渡して接続

C:\work>mongo --host 127.0.0.1:8001 -u user -p password --authenticationDatabase test

接続後にユーザー名とパスワードを指定する方法

単純に任意のサーバーへ接続します。

C:\work>mongo --host 127.0.0.1:8001
MongoDB shell version v3.6.2
connecting to: mongodb://127.0.0.1:8001/
MongoDB server version: 3.6.2
MongoDB Enterprise rs0:PRIMARY>

接続で来たら認証したいデータベースへスイッチ（use）して認証（db.auth()）を行います。

MongoDB Enterprise rs0:PRIMARY> use test
switched to db admin
MongoDB Enterprise rs0:PRIMARY> db.auth("user", "password")
1
MongoDB Enterprise rs0:PRIMARY>

アクセス制御が有効化されている場合に必要な権限

データベース自身に対する読み書き権限

read
readWrite

レプリカセットに対する操作権限

clusterAdmin
clusterManager
clusterMonitor

読み書きしたいデータベースに対して readWrite があり、レプリカセットの状態確認に clusterMonitor があればとりあえずは事足りるかと思います。

読み書きする

レプリカセットで書き込みができるのは唯一プライマリサーバーのみです。セカンダリサーバーでは読み取りのみになります。

プライマリサーバーで読み書き

プライマリサーバーは単一ノードの場合と同じで通常通りのコマンド実行ができます。

PRIMARY> db.orders.find()

PRIMARY> db.orders.insert({ name: "orange", amount: 4 })

セカンダリサーバーで読取

セカンダリサーバーで読取操作を行う場合、あらかじめセカンダリサーバーへ接続した後、読取設定（rs.slaveOk()）を行う必要があります。

SECONDARY> rs.slaveOk()

上記コマンドを一度実行した後は通常通り読み取り操作が利用できます。

SECONDARY> db.orders.find()

今回は「MongoDB のレプリカセットにmongoシェルを使ってアクセスする方法」についてまとめました。ポイントは以下の通りです。

rs.status() でプライマリサーバーを探す
セカンダリサーバーで読取する場合は rs.slaveOk() を実行する

参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

MongoDB のレプリカセットでアクセス制御（ユーザー認証）を有効化する方法

今回は「MongoDB のレプリカセットに対してアクセス制御（ユーザー認証）を有効化する方法」についてまとめます。

概要
キーファイルを用いたアクセス制御

概要

レプリカセットに対するアクセス制御を有効化するためには内部認証（レプリカセットメンバー間の認証）を有効化する必要があります。内部認証の方法は以下の2通りがあります。

キーファイル (チャレンジレスポンス認証、SCRAM-SHA-1)
x.509（公開鍵認証、TLS/SSL）

今回はお手軽に実現できる「キーファイル」を用いた内部認証の有効化およびアクセス制御の有効化を行います。

キーファイルを用いたアクセス制御

管理ユーザーの追加

アクセス制御を有効化する前に管理ユーザーを作っておきます。

アクセス制御無効化状態でMongoDBのすべてのレプリカセットメンバーを起動
```
mongod --config "C:\mongodb\server1\server1.cfg"
```
プライマリサーバーに接続

mongoシェルでプライマリサーバーに接続します。プライマリサーバーが不明な場合、 rs.status() でプライマリサーバーを確認して接続しなおします。
```
mongo --host 127.0.0.1:8001
```
管理ユーザーを追加

以下のコマンドのように、adminデータベースへスイッチしたのち、管理ユーザーを作成します。

レプリカセットコマンドである rs.xxxx を利用できるのは clusterMonitor というロールのようですが、ここでは clusterAdmin ロールを追加しています。
```
PRIMARY> use admin
PRIMARY> db.createUser({
  user: "admin",
  pwd: "password",
  roles: [
    "userAdminAnyDatabase",
    "dbAdminAnyDatabase",
    "clusterAdmin"
  ]
})
```

MongoDBの設定変更（アクセス制御有効化）

キーファイルの作成

キーファイルは Base64セットの文字列（[a-zA-Z0-9/+] の64種類）を使った 6～1024文字のファイルになります。ランダム文字列生成した後、Base64変換して1024文字までにカットするような方法で良いかと思います。 Linux使えるなら openssl を使った以下のコマンドでランダム文字列を生成できます。
```
$ openssl rand -base64 1024 > keyfile
```
キーファイルは以下のようなBase64文字列で構成される内容になります。以下はサンプルなので、必ず自前で生成してください。ランダム文字列生成するツールを使うとラクかもしれません。

keyfile
```
rMvhlWEIzktbhXN+rcTV43z2YKPGsd8YHNNuOVpZLW9bIPx1MaAeGTVullFVY4A5
B0zRpKLXcB347T/m278LK3BNBynB3mVpoe1pPmSYVjpBmo3LhsDKXywb8dU7UrBl
9bgh4NZfNaBcYykuoQsiloWNP5QtMquBymF2bh+1s+aJpvkq1FzAhsJvwcGeILBc
gnBOwZAsDXlE0M1hr0zvsulkyvFDgE2UcS+2tm4yZPKNDygA2HCcXqJypa9L2f1J
dC83SLNxbN4MkeE+NeY3ZE+LFUqTyvb827VhXfCX+S+TpD5h/otiS1GiQnTcBiSB
fYrMhLsOFPU9UYc705XDw48m
```
ランダム文字列生成ツール
キーファイルをレプリカセットメンバーへ配布

任意の方法で各レプリカセットメンバーに作成したキーファイルを配置します。今回はサンプルとして以下のような場所に配置したものとします。
```
C:\mongodb
  │
  ├ \server1
  │  └ keyfile
  │     
  ├ \server2
  │  └ keyfile
  │     
  └ \server3
      └ keyfile
```

すべてのレプリカセットメンバー設定に認証設定を追加

MongoDB設定ファイル（mongod.config）に対して security.authorization を有効化し、 security.keyFile 設定を追加します。

mongod.config

systemLog:
  destination: file
  path: C:\mongodb\server1\log\mongod.server1.log
  logAppend: true
  logRotate: "rename"
storage:
  dbPath: C:\mongodb\server1\data
security:
  authorization: enabled
  keyFile: C:\mongodb\server1\keyfile
replication:
  replSetName: "rs0"
net:
  bindIpAll: true
  port: 8001

すべてのレプリカセットメンバーを再起動

各サーバーに mongoシェルでログインして以下のコマンドを実行してサーバーを停止させます。サーバーを停止させる際、ロールバックを避けるため、プライマリサーバーが最後になるよう停止していきます。

停止
```
SECONDARY> use admin
SECONDARY> db.shutdownServer()
```
開始
```
mongod --config "C:\mongodb\server1\server1.cfg"
```

通常ユーザーの追加

プライマリサーバーに管理ユーザーで接続

mongoシェルでプライマリサーバーに管理ユーザーで接続します。プライマリサーバーが不明な場合、 rs.status() でプライマリサーバーを確認して接続しなおします。

接続方法は「接続時にユーザー名とパスワードを指定する方法」と「接続語にユーザー名とパスワードを指定する方法」の2通りがあります。
- MongoDB へ接続と同時に認証する
```
mongo --host 127.0.0.1:8001 -u admin -p Passw0rd --authenticationDatabase admin
```
- MongoDB へ接続、接続後に認証する
```
mongo --host 127.0.0.1:8001
```
```
PRIMARY> use admin
PRIMARY> db.auth('admin', 'Passw0rd')
```

通常ユーザーを追加

データベースを指定して通常ユーザーを追加します。

PRIMARY> use test
PRIMARY> db.createUser({
  user: "test",
  pwd: "test",
  roles: [{
    role: "readWrite",
    db: "test"
  }]
})

ユーザー名とパスワードを指定してデータベースへ接続

プライマリサーバーに通常ユーザーで接続

mongoシェルでプライマリサーバーに通常ユーザーで接続します。

接続方法は管理ユーザーで接続するのと同じで、「接続時にユーザー名とパスワードを指定する方法」と「接続語にユーザー名とパスワードを指定する方法」の2通りがあります。
- MongoDB へ接続と同時に認証する
```
mongo --host 127.0.0.1:8001 -u test -p test --authenticationDatabase test
```
- MongoDB へ接続、接続後に認証する
```
mongo --host 127.0.0.1:8001
```
```
PRIMARY> use test
PRIMARY> db.auth(test, test)
```

今回は「MongoDB のレプリカセットに対してキーファイルを用いたアクセス制御（ユーザー認証）を有効化する方法」についてまとめました。ポイントは以下の通りです。

MongoDBのレプリカセットでアクセス制御は「キーファイル」と「x.509」の2種類が選べる
アクセス制御有効化前に管理ユーザーを作成しておく

参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

参考記事

MongoDB の既存レプリカセットからメンバーを削除する方法

MongoDB の既存レプリカセットにメンバーを追加する方法

今回は「MongoDBの既存レプリカセットに新しいメンバーを追加する方法」についてまとめます。

前提・制約
レプリカセットへの追加手順

前提・制約

MongoDBのレプリカセットにおけるそもそもの制約も含めて追加しようとしている新しいMongoDBサーバーが以下の前提や制約を満たしていることを確認しておきます。

有効なレプリカセットが既に存在している
追加したい新しいMongoDBは有効なレプリカセットにアクセス可能な状態
追加するメンバーを含めて投票権は7台以下になっている
追加するメンバー含めてレプリカセット全体が50台以下になっている

レプリカセットへの追加手順

レプリカセットに追加

MongoDBを起動

mongod --config "C:\mongodb\server4\mongod4.cfg"

プライマリサーバーに接続

プライマリサーバーが不明な場合、任意のサーバーに接続して rs.status() を実行することでプライマリサーバーがどれか確認できます。
```
mongo --host 127.0.0.1:8001
```
レプリカセットに追加する新しいメンバー情報を作成

優先度(priority）、隠し（hidden）、遅延（slaveDelay）など必要な設定があれば合わせて準備しておきます。
```
PRIMARY> member = { host: "127.0.0.1:8004" }
```
アービターの場合、以下のように arbiterOnly を設定しておきます。
```
PRIMARY> member = { host: "127.0.0.1:8004", arbiterOnly: true }
```
レプリカセットに新規メンバーを追加
```
PRIMARY> rs.add(member)
```

追加したメンバーのデータ確認

レプリカセットメンバーに追加されると自動的にデータ同期が始まります。データ同期されていることを以下の手順で確認します。

追加したメンバーへ接続
```
mongo --host 127.0.0.1:8004
```
参照設定変更

セカンダリ接続しただけだとデータ参照できないので、以下の mongoシェルを実行して参照できるようにします。
```
SECONDARY> rs.slaveOk()
```
データ確認

以下はサンプルとして test データベースの users コレクションを参照するようなコードです。存在する任意のコレクションを確認してみてください。
```
SECONDARY> use test
SECONDARY> db.users.find()
```

新規メンバーのデータを同期

基本的にはデータは自動的に同期されますが、何かしらの理由でうまくいかなかった場合、以下の手順で強制的に再同期させます。

追加した新規メンバーを停止

追加した新規メンバーに mongoシェルでログインし、以下のコマンドを実行します。
```
> use admin
> db.shutdownServer()
```
追加したMongoDBサーバーの dbPath 配下のファイル・フォルダを削除

追加した後に再同期を自動的におこなえるようにするため、 dbPath 配下のファイル・フォルダは削除しておきます。
追加した新規メンバーを起動

コマンドプロンプト上で以下のコマンドを実行します。
```
mongo --config "C:\mongo\server4\server4.cfg"
```

今回は「MongoDBの既存レプリカセットに新しいメンバーを追加する方法」についてまとめました。参考になったでしょうか？本記事がお役に立っていると嬉しいです！！

C# & JavaScript

前提状況

優先度の調整で変更する

コマンドで変更する

概要

変更手順

現在のサイズを確認

oplogサイズ変更

データ再同期

接続する

接続文字列 (url)

読み込み設定 (options)

書き込み設定

読み書きする

接続する

サーバーを指定して接続する

プライマリサーバーを探す

ユーザー名とパスワードを指定して接続する

アクセス制御が有効化されている場合に必要な権限

読み書きする

プライマリサーバーで読み書き

セカンダリサーバーで読取

概要

キーファイルを用いたアクセス制御

管理ユーザーの追加

MongoDBの設定変更（アクセス制御有効化）

通常ユーザーの追加

ユーザー名とパスワードを指定してデータベースへ接続

前提・制約

レプリカセットからメンバーを削除する手順

前提・制約

レプリカセットへの追加手順

レプリカセットに追加

追加したメンバーのデータ確認

新規メンバーのデータを同期