reshardCollection

初期化フェーズ

初期化フェーズ中に、リシャーディング コーディネーターはシャーディングされたコレクションの新しいデータ分散を決定します。

クローン フェーズ

クローン フェーズ実行中:

• 各受信者シャードは、ドナーのシャーディングされたコレクションと同じコレクションオプションを持つ一時的な空のシャーディングされたコレクションを作成します。 この新しいコレクションは、受信者シャードが新しいデータを書き込むターゲットです。 受信者シャードは、インデックスフェーズまで、_idインデックス以外のインデックスを作成しません。

• 各受信者シャードは、新しいシャードキーの下で受信者シャードが所有するすべてのドキュメントを含む、ドナー シャードからのコレクションデータを複製します。

インデックス フェーズ

インデックスフェーズでは、各受信者シャードは必要な新しいインデックスをビルドします。 これらには、シャーディングされたコレクションの既存のすべてのインデックスと、新しいシャードキーパターン と互換性のあるインデックス（シャーディングされたコレクションにインデックスがまだ存在しない場合）が含まれます。

適用フェーズとキャッチアップ フェーズ

適用フェーズとキャッチアップフェーズ中:

• 各受信者シャードは、受信者がデータをクローンした後に対応するドナー シャードに書込まれたoplogエントリの適用を開始します。

• リシャーディング操作を完了するための残り時間が 2 秒未満の場合、ドナー シャードはソースコレクションへの書込みをブロックします。

コミット フェーズ

コミット フェーズ実行中:

• リシャーディング コーディネーターは、すべてのシャードが厳密な一貫性に達するまで待機し、 リシャーディング操作 をコミットします。

• リシャーディング コーディネーターは、各ドナー シャード プライマリと受信者シャード プライマリに対して、一時的にシャーディングされたコレクションの名前を変更するよう、個別に指示します。 一時的なコレクションは、新しいリシャーディングされたコレクションになります。

• 各ドナー シャードは、古いシャーディングされたコレクションを削除します。

コレクションの再シャーディング

次の例では、 sales.ordersコレクションを新しいシャードキー{ order_id: 1 }で再シャーディングします。

db.adminCommand({
  reshardCollection: "sales.orders",
  key: { order_id: 1 }
})

出力:

{
  ok: 1,
  '$clusterTime': {
    clusterTime: Timestamp(1, 1624887954),
    signature: {
      hash: Binary(Buffer.from("0000000000000000000000000000000000000000", "hex"), 0),
      keyId: 0
    }
  },
  operationTime: Timestamp(1, 1624887947)
}

新しいシャードへのデータの再配布

MongoDB 8.0 以降では、同じキーでコレクションを再シャーディングできます。これを使用して、新しいシャードにデータを再配布できます。

クラスターにシャードを追加した後、 reshardCollectionコマンドとforceRedistributionオプションを併用して、クラスター全体にデータを再分散します。

db.adminCommand({
    reshardCollection: "accounts.invoices",
    key: { store_id: "hashed" },
    forceRedistribution: true
})

異なるゾーンへのデータの再配布

MongoDB 8.0 以降では、 reshardCollection コマンドを使用して、シャードキー を変更せずにデータを新しいゾーンに移動できます。

次のコマンドは、同じシャードキーを使用して accounts.salesコレクションのデータを再配布し、ゾーン zone04 と zone05 に関連付けられているシャードにデータを移動します。

db.adminCommand({
    reshardCollection: "accounts.sales",
    key: { region_id: "hashed" },
    forceRedistribution: true,
    zones: [
        {
            zone: "zone04",
            min: { region_id: MinKey() },
            max: { region_id: 10 }
        },
        {
            zone: "zone05",
            min: { region_id: 10 },
            max: { region_id: MaxKey() }
        }
    ]
})