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

このタスクについて

• 一度にリシャーディングできるコレクションは 1 つだけです。

• writeConcernMajorityJournalDefaultはtrueである必要があります。

• 一意の制約があるコレクションを再シャーディングするには、新しいシャードキーが既存の一意なインデックスの一意なインデックス要件を満たす必要があります。

• 次のコマンドと対応する shell メソッドは、再シャーディング操作の進行中に再シャーディングされるコレクションではサポートされていません。

  • collMod

  • convertToCapped

  • createIndexes

  • createIndex()

  • drop

  • drop()

  • dropIndexes

  • dropIndex()

  • renameCollection

  • renameCollection()

• 次のいずれかの操作を実行する場合、その操作は再シャーディングが完了するまで待機してから実行されます。

  • addShard

  • removeShard

  • dropDatabase 、再シャーディング中のコレクションをホストしているデータベース上

• リシャーディングしているコレクションが Atlas Search を使用している場合、リシャーディング操作の完了時に検索インデックスは使用できなくなります。再シャーディング操作が完了してから、検索インデックスを手動で再構築する必要があります。

始める前に

コレクションを再シャーディングする前に、次の要件を満たしていることを確認してください。

• アプリケーションは、影響を受けるコレクションが書込みをブロックする期間を2 秒許容できます。 書込み (write) がブロックされている期間中、アプリケーションのレイテンシが増加します。

  ワークロードがこの要件を許容できない場合は、代わりにシャードキーの改良を検討してください。

• データベースが次のリソース要件を満たしている。

  • 各受信者シャードで使用可能なストレージ領域が、少なくとも再シャーディングするコレクションのストレージサイズとその合計インデックスサイズの 2 倍をシャード数で割ったものであることを確認します。

    ( ( collection_storage_size + index_size ) * 2 ) / shard_count = storage_req

    例、ストレージサイズが 2 TB データと 400 GB インデックスのコレクションを考えてみましょう。これを 4 つのシャードに分散するには、次のものが必要です。

    ( ( 2 TB collection + 0.4 TB index ) * 2 ) / 4 shards = 1.2 TB storage

    このコレクション を再シャーディングするには、各シャードに 1.2 が必要です利用可能なストレージの TB

    MongoDB Atlasでは、再シャーディング操作のためにストレージの次の階層にアップグレードする必要がある場合があります。操作が完了したらダウングレードできます。

  • I/Oキャパシティーが50 % 未満であることを確認します。

  • CPU 負荷が80 % 未満であることを確認します。

  重要

  これらの要件はデータベースによって強制されません。 十分なリソースを割り当てられない場合、次の結果が発生する可能性があります。

  • データベースの容量が不足し、シャットダウンした

  • パフォーマンスの低下

  • 操作に予想よりも時間がかかる

  アプリケーションにトラフィックが少ない期間がある場合は、可能であれば、その時間中にコレクションに対してこの操作を実行します。

• リシャーディングの前に、新しいシャードキーにインデックスを作成する必要はありません。リシャーディング操作、インデックスフェーズ中に必要なインデックスが自動的に構築されます。

• インデックスのビルドは進行中ではありません。インデックスビルドが実行中どうかを確認するには、$currentOp を使用します。

  db.getSiblingDB("admin").aggregate( [
     { $currentOp : { idleConnections: true } },
     { $match: {
           $or: [
               { "op": "command", "command.createIndexes": { $exists: true } },
               { "op": "none", "msg": /^Index Build/ }
           ]
        }
     }
  ] )

  結果ドキュメントでは、 inprogフィールド値が空の配列の場合、インデックスビルドは進行中ではありません。

  {
     inprog: [],
     ok: 1,
     '$clusterTime': { ... },
     operationTime: <timestamp>
  }

手順

コレクションの再シャーディング操作では、シャードは次のようになります。

• ドナーは、シャーディングされたコレクションのチャンクを現在保存しています。

• 受信者。シャードキーとゾーンに基づいてシャーディングされたコレクションの新しいチャンクを保存します。

シャードは同時にドナーでも受信者でもあることができます。

コンフィギュレーションサーバーのプライマリは常にリシャーディング コーディネーターであり、リシャーディング操作の各フェーズを開始します。

db.adminCommand({
  reshardCollection: "<database>.<collection>",
  key: <shardkey>
})

db.adminCommand({
  reshardCollection: "<database>.<collection>",
  key: <shardkey>,
  forceRedistribution: true
})

db.getSiblingDB("admin").aggregate([
  { $currentOp: { allUsers: true, localOps: false } },
  {
    $match: {
      type: "op",
      "originatingCommand.reshardCollection": "<database>.<collection>"
    }
  }
])

[
  {
    shard: '<shard>',
    type: 'op',
    desc: 'ReshardingRecipientService | ReshardingDonorService | ReshardingCoordinatorService <reshardingUUID>',
    op: 'command',
    ns: '<database>.<collection>',
    originatingCommand: {
      reshardCollection: '<database>.<collection>',
      key: <shardkey>,
      unique: <boolean>,
      collation: { locale: 'simple' }
    },
    totalOperationTimeElapsedSecs: <number>,
    remainingOperationTimeEstimatedSecs: <number>,
    ...
  },
  ...
]

動作

エラーケース