シャーディングされたクラスター バランサーの管理

バランサーの状態の確認

sh.getBalancerState() は、バランサーが有効かどうか（すなわち、バランサーの実行が許可されているかどうか）を確認します。sh.getBalancerState() は、バランサーがアクティブにデータを移行するかどうかを確認しません。

シャーディングされたクラスターでバランサーが有効になっているかどうかを確認するには、次のコマンドを実行します。このコマンドはブール値を返します。

sh.getBalancerState()

sh.status() を使用して、バランサーが有効かどうかも確認できます。currently-enabled フィールドはバランサーが有効かどうかを示し、currently-running フィールドはバランサーが現在実行中かどうかを示します。

バランサーが実行中であることを確認します

クラスターでバランサーのプロセスがアクティブかどうかを確認する方法は次のとおりです。

1. mongosh shell を使用して、クラスター内の任意の mongos に接続します。

2. バランサーが実行中かどうかを確認するには、次の操作を使用します。

   sh.isBalancerRunning()

デフォルトの範囲サイズの構成

シャーディングされたクラスターのデフォルトの範囲サイズは 128 メガバイトです。ほとんどの場合、チャンクの分割と移行にはデフォルトのサイズが適切です。範囲サイズが配置に与える影響について、詳細は「範囲サイズ」を参照してください。

デフォルトの範囲サイズを変更すると、移行および自動分割中に処理される範囲に影響しますが、すべての範囲に遡及して影響するわけではありません。

デフォルトのチャンク サイズを変更すると、移行および自動分割中に処理されるチャンクに影響しますが、すべてのチャンクには遡及して影響するわけではありません。

MongoDB 6.0.3 以降では、自動チャンク分割は実行されません。 これはバランシング ポリシーの改善によるものです。 自動分割コマンドは引き続き存在しますが、操作は実行されません。 詳細については、「バランシング ポリシーの変更 」を参照してください。

デフォルトの範囲サイズを構成するには、「シャーディングされたクラスターの範囲サイズの変更」を参照してください。

バランシング ウィンドウのスケジュール

状況によっては、特にデータセットの増大が遅く、移行がパフォーマンスに影響する可能性がある場合、バランサーを特定の時間のみアクティブにしておくと便利です。次の手順では、バランサーがチャンクを移行できる時間枠である activeWindow を指定します。

use config

sh.startBalancer()

db.settings.updateOne(
   { _id: "balancer" },
   { $set: { activeWindow : { start : "<start-time>", stop : "<stop-time>" } } },
   { upsert: true }
)

バランシング ウィンドウのスケジュールの削除

バランシング ウィンドウを設定しており、スケジュールを削除してバランサーが常に実行されるようにする場合は、次のように$unsetを使用してactiveWindowをクリアします。

use config
db.settings.updateOne( { _id : "balancer" }, { $unset : { activeWindow : true } } )

バランサーを無効にする

デフォルトでは、バランサーはいつでも実行でき、必要な場合にのみチャンクを移動します。バランサーを短期間無効にしてすべての移行を防ぐ場合は、次の手順に従います。

1. mongosh shellを使用して、クラスター内の任意の mongos に接続します。

2. 次の操作を発行して、バランサーを無効にします。

   sh.stopBalancer()

   移行が進行中の場合、システムは進行中の移行を完了してから停止します。

   MongoDB 6.0.3 以降では、自動チャンク分割は実行されません。 これはバランシング ポリシーの改善によるものです。 自動分割コマンドは引き続き存在しますが、操作は実行されません。 詳細については、「バランシング ポリシーの変更 」を参照してください。

   MongoDB バージョン 6.0.3 より前では、sh.stopBalancer() によってシャーディングされたクラスターの自動分割も無効になります。

3. バランサーが起動しないことを確認するには、次のコマンドを実行します。このコマンドは、バランサーが無効になっている場合はfalseを返します。

   sh.getBalancerState()

   オプションとして、無効化後に移行が進行中でないことを確認するには、mongosh shellで次の操作を実行します。

   use config
   while( sh.isBalancerRunning() ) {
             print("waiting...");
             sleep(1000);
   }

db.adminCommand( { balancerStop: 1 } )

バランサーを有効にする

バランサーを無効にし、再度有効にする準備ができたら、次の手順に従います。

1. mongosh shellを使用して、クラスター内の任意の mongos に接続します。

2. 次のいずれかの操作を発行して、バランサーを有効にします。

   mongosh shell から次を発行します。

   sh.startBalancer()

   注意

   ドライバーからバランサーを有効にするには、次のように admin データベースに対して balancerStart コマンドを使用します。

   db.adminCommand( { balancerStart: 1 } )

   MongoDB 6.0.3 以降では、自動チャンク分割は実行されません。 これはバランシング ポリシーの改善によるものです。 自動分割コマンドは引き続き存在しますが、操作は実行されません。 詳細については、「バランシング ポリシーの変更 」を参照してください。

   MongoDB バージョン 6.0.3 より前では、sh.startBalancer() によってシャーディングされたクラスターの自動分割も有効になります。

バックアップ中のバランシングの無効化

MongoDB がバックアップ中にチャンクを移行すると、シャーディングされたクラスターのスナップショットが不整合になる可能性があります。バランサーがアクティブな間はバックアップを実行しないでください。バックアップ操作中にバランサーが非アクティブであることを確認する方法。

• バランシング ウィンドウを設定して、バックアップ中にバランサーが非アクティブになるようにします。 バランサーを無効にした状態でバックアップが完了することを確認します。

• バックアップ手順の実行中にバランサーを手動で無効にする。

バランサー ラウンドの最中にバランサーの電源を切ると、瞬時にはシャットダウンされません。バランサーは進行中のチャンクの移動を完了し、それ以降のバランサー ラウンドをすべて中止します。

バックアップ操作を開始する前に、バランサーがアクティブでないことを確認してください。次のコマンドを使用して、バランサーがアクティブかどうかを確認できます。

!sh.getBalancerState() && !sh.isBalancerRunning()

バックアップ手順が完了したら、バランサー プロセスを再度有効化できます。

コレクションでのバランシングの無効化

sh.disableBalancing() メソッドを使用して、特定のコレクションのバランシングを無効にできます。データの取り込みやデータのエクスポートなどの最中に、メンテナンス操作や非定型のワークロードをサポートするために、特定のコレクションのバランサーを無効にしたい場合があります。

コレクションのバランシングを無効にすると、MongoDB は進行中の移行を中断しません。

コレクションのバランシングを無効にするには mongosh shellを使用して mongos に接続し、sh.disableBalancing() メソッドを呼び出します。

以下に例を挙げます。

sh.disableBalancing("students.grades")

sh.disableBalancing() メソッドは、コレクションの完全な名前空間をパラメータとして受け入れます。

コレクションでのバランシングの有効化

sh.enableBalancing() メソッドを使用して、特定のコレクションのバランシングを有効にできます。

コレクションのバランシングを有効にしても、MongoDB はデータのバランシングをすぐには開始しません。しかし、シャーディングされたコレクションのデータがバランシングされていない場合、MongoDB はデータのより均等な分散を始めることができます。

コレクションのバランシングを有効にするには、 shellmongos mongoshsh.enableBalancing()を使用して に接続し、 メソッドを呼び出します。

以下に例を挙げます。

sh.enableBalancing("students.grades")

sh.enableBalancing() メソッドは、コレクションの完全な名前空間をパラメータとして受け入れます。

バランシングが有効か無効かの確認

コレクションのバランシングが有効か無効かを確認するには、コレクション名前空間の config データベース内の collections コレクションをクエリし、noBalance フィールドを確認します。以下に例を挙げます。

db.getSiblingDB("config").collections.findOne({_id : "students.grades"}).noBalance;

この操作は null エラー、true、false を返すか、出力なしになります。

• null エラーは、コレクションの名前空間が正しくないことを示します。

• 結果が true の場合、バランシングは無効になります。

• 結果が false の場合、コレクションのバランシングは現在は有効ですが、過去には無効になっていました。このコレクションのバランシングは、バランサーが次に実行するときに開始します。

• 操作で出力が返されない場合は、バランシングは現在有効で、このコレクションで過去に無効になったことはありません。このコレクションのバランシングは、バランサーが次に実行するときに開始します。

sh.status() を使用して、バランサーが有効かどうかも確認できます。currently-enabled フィールドは、バランサーが有効かどうかを示します。

チャンク移行のレプリケーション動作の変更

use config
db.settings.updateOne(
   { "_id" : "balancer" },
   { $set : { "_secondaryThrottle" : { "w": "majority" }  } },
   { upsert : true }
)

db.getSiblingDB("config").settings.updateOne(
   { _id: "balancer" },
   { $set: { attemptToBalanceJumboChunks : true } },
   { upsert: true }
)

特定のシャードの最大ストレージサイズの変更

デフォルトでは、シャードにはストレージ サイズの制約はありません。 ただし、シャーディングされたクラスター内の特定のシャードの最大ストレージ サイズを設定できます。 潜在的な宛先シャードを選択する場合、バランサーは移行が設定された最大ストレージサイズを超えるシャードを無視します。

コンフィギュレーションshards データベース の コレクションには、シャードに関連する構成データが保存されています。

{ "_id" : "shard0000", "host" : "shard1.example.com:27100" }
{ "_id" : "shard0001", "host" : "shard2.example.com:27200" }

特定のシャードのストレージ サイズを制限するには、 演算子を使用してdb.collection.updateOne() $setメソッドを使用してmaxSize フィールドを作成し、そのフィールドにinteger 値を割り当てます。maxSizeフィールドは、 megabytes内のシャードの最大ストレージ サイズを表します。

次の操作では、シャードの最大サイズを1024 megabytesに設定します。

config = db.getSiblingDB("config")
config.shards.updateOne( { "_id" : "<shard>"}, { $set : { "maxSize" : 1024 } } )

この値には、 データベースと データベースを含む、シャード上のlocal すべてのadmin データファイルのマッピングされたサイズが含まれます。

デフォルトでは、 maxSizeは指定されていないため、シャードは必要に応じてマシン上の利用可能なスペースの合計量を消費することができます。

シャードを追加するときにmaxSizeを設定することもできます。

シャードを追加するときにmaxSizeを設定するには、 addShardコマンドのmaxSizeパラメータをmegabytesの最大サイズに設定します。 mongosh shell で実行される次のコマンドは、最大サイズが125メガバイトのシャードを追加します。

config = db.getSiblingDB("config")
config.runCommand( { addshard : "example.net:34008", maxSize : 125 } )