Atlas Infinite クラスターへデータをロードする

ソース配置でデータベースユーザーを設定します。

ソース配置で認証が強制されている場合、mongodumpは、移行するすべてのデータベースを読み取ることができるデータベースユーザーとして認証する必要があります。adminデータベースのbackupロールは、これらの権限を付与します。

ソース配置にそのようなユーザーが存在しない場合は、作成してください。データベースユーザーの作成と管理方法については、配置タイプに応じて次のページを参照してください。

• Atlasマネージドクラスターについては、「データベースユーザーの構成」を参照してください。

• 自己管理型配置については、「自己管理型配置でのユーザーとロールの管理」を参照してください。

宛先 Atlas Infinite クラスターにデータベースユーザーを設定します。

mongorestoreは、移行するすべてのデータベースに書き込み (write)ができるデータベースユーザーとして認証する必要があります。移行先のAtlas InfiniteクラスターのAtlas adminロールは、これらの権限を付与します。

そのようなユーザーが宛先のAtlas Infiniteクラスターに存在しない場合は、作成してください。Atlasでデータベースユーザーを作成および管理する方法を学ぶには、データベースユーザーの構成を参照してください。

ソースおよび宛先の配置へのホストネットワークアクセスを許可します。

mongodump と mongorestore を実行するホストする側から両方の配置に到達できることを確認します。

• 宛先の Atlas Infinite クラスターを含むプロジェクトの IP アクセス リストにホストするを追加します。ホストを IP アクセス リストに追加する方法については、「IP アクセス リスト エントリの設定」を参照してください。

• ソースの配置が別のプロジェクトの Atlas Core クラスターである場合は、そのプロジェクトの IP アクセス リストにもホストするを追加します。ソースの配置が自己管理型の場合は、ホストからの接続を受け入れるようにファイアウォールを構成します。詳細を学ぶには、ネットワークと設定の強化を参照してください。

VPCピアリングを設定する場合、ピアの VPC CIDR ブロックまたはサブネット、またはピア VPC のセキュリティ グループを IP アクセス リストに追加できます。詳細については、「IP アクセス リスト」を参照してください。

mongodump を実行する。

1. mongodumpコマンドをアセンブルします。

   次の mongodump コマンドテンプレートは、接続文字列を使用してソースレプリカセットまたはスタンドアロンクラスターに接続し、ダンプのアーカイブをファイルに出力します。

   テンプレートを任意のテキストエディターにコピーし、<connectionString> プレースホルダーをソース配置の接続文字列に、<fileName> を作成するアーカイブ ファイルの名前に置き換えます。

   mongodump --uri "<connectionString>" --archive=<fileName>.archive

   ソース配置の接続文字列を構築する学ぶ方法については、接続文字列を参照してください。

   注意

   Ubuntu 18.04でmongodumpまたはmongorestoreを使用している場合、 SRV 接続文字列（ mongodb+srv://形式）を--uriオプションとともに使用すると、 cannot unmarshal DNSエラー メッセージが表示されることがあります。 その場合は、次のいずれかのオプションを代わりに使用します。

   • 非 SRV 接続string （mongodb:// 形式）と --uri オプション

   • 直接接続するホストを指定するための--hostオプション

2. ソース配置へのネットワークアクセス権を持つホストのターミナルまたはコマンドプロンプトから、完成したコマンドを実行します。

   例

   次の mongodump コマンドは、SRV 接続文字列を使用してソース Atlas Core クラスターに接続します。この文字列には、admin データベースで backup ロールを持つデータベースユーザーのユーザー名 (mySourceUsername) とパスワード (mySourcePassword) が含まれています。このコマンドは、ダンプのアーカイブを現在の作業ディレクトリにある mongodump.archive という名前のファイルに出力します。

   mongodump --uri "mongodb+srv://mySourceUsername:mySourcePassword@cluster0.example.mongodb.net" \          --archive="mongodump.archive"

mongorestore を実行する。

1. mongorestoreコマンドをアセンブルします。

   次の mongorestore コマンド テンプレートは、接続先の Atlas Infinite クラスターに接続文字列を使用して接続し、mongodump によって作成されたアーカイブを復元しまます。これは、--nsExclude を使用して、Atlas がマネージドしている admin と config データベースを除外します。

   テンプレートを好みのテキストエディタにコピーし、以下のプレースホルダーを適切な値に置き換えます。

   • <connectionString>: これを宛先 Atlas Infinite クラスター用の SRV 接続文字列に置き換えてください。宛先クラスターの接続文字列を検索または構築するには、接続文字列を参照してください。

     Atlas admin ロールを持つデータベースユーザーのユーザー名とパスワードを接続文字列に含めます。

   • <filePath>: これと、によって作成されたアーカイブファイルへのパスを置き換えてください。mongodump。

   注意

   ユーザー名またはパスワードに次の文字が含まれている場合、それらの文字は パーセント エンコーディング を使用して変換する必要があります。

   $ : / ? # [ ] @

   mongorestore --uri "<connectionString>" \             --archive="<filePath>" \             --nsExclude "admin.*" \             --nsExclude "config.*"

2. mongodumpによって作成されたアーカイブファイルにアクセスできるホストする上のターミナルまたはコマンドプロンプトから、完成したコマンドを実行します。

   例

   次の mongorestore コマンドは、Atlas admin ロールを持つデータベースユーザーのユーザー名 (myDestinationUsername) とパスワード (myDestinationPassword) を含む SRV 接続文字列を使用して Atlas Infinite クラスターに接続します。このコマンドは、mongodump によって作成された mongodump.archive にあるアーカイブを復元します。ただし、admin データベースと config データベースは除外されます。

   mongorestore --uri "mongodb+srv://myDestinationUsername:myDestinationPassword@cluster0.example.mongodb.net" \          --archive="mongodump.archive" \          --nsExclude "admin.*" \          --nsExclude "config.*"

移行を検証します。

移行が完了したら、Atlas Infiniteクラスターに接続し、データが正常に移行されたことを確認します。クエリを実行して、移行先クラスターにコレクションとドキュメントが存在することを確認できます。

アプリケーションを更新し、Atlas Infinite クラスターに差し向けます。

移行を確認した後、アプリケーションを更新して、ソースの配置ではなくAtlas Infiniteクラスターに接続するようにします。Atlas Infiniteクラスターに対して正しい接続文字列と認証情報を使用していることを確認してください。

Atlas で、プロジェクトの Database & Network Access ページに移動します。

1. まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。

2. まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。

3. サイドバーで、 Security見出しの下のDatabase & Network Accessをクリックします。

前の手順を完了すると、[ データベースとネットワーク アクセス ] ページが表示されます。

移行先 Atlas クラスターに、データベースユーザーを設定します。

mongoimportを実行してAtlasクラスターに書き込み (write)には、データをインポートするデータベースでreadWrite権限を持つデータベースユーザーを指定する必要があります。たとえば、Atlas adminロールを持つユーザーにはこれらの権限が付与されます。

そのようなユーザーが存在しない場合は、ユーザーを作成します。

1. まだ表示されていない場合は Database Users タブをクリックします。

2. Add New Database User をクリックします。

3. Atlas admin ユーザーを追加します。

Atlas で、プロジェクトの Clusters ページに移動します。

1. まだ表示されていない場合は、希望するプロジェクトを含む組織を選択しますナビゲーション バーのOrganizationsメニュー

2. まだ表示されていない場合は、ナビゲーション バーのProjectsメニューから目的のプロジェクトを選択します。

3. サイドバーで、 Database見出しの下のClustersをクリックします。

[ Clusters （クラスター） ] ページが表示されます。

[Connect] をクリックします。

データを移行する Atlas クラスターのConnectをクリックします。

IP アクセス リストを更新します。

mongoimportを実行するホストがIP アクセス リストにない場合は、更新します。次のいずれかを指定できます。

• mongoimport が実行されるサーバーのパブリック IP アドレス、または

• VPC ピアリングを設定する際、クラウドプロバイダーとして AWS を選択した場合、ピア VPC の CIDR ブロック（またはサブネット）またはピア VPC のセキュリティグループのいずれかとなります。

宛先クラスターの URI / ホスト情報をコピーします。

MongoDB Atlas クラスターには、接続文字列 URI を使用して接続できます。接続ダイアログボックスで、次の手順を実行します。

1. [Drivers] をクリックします。

2. 手順 1 で見つかった接続文字列をコピーします。

3. PASSWORD を root ユーザーのパスワードに置き換え、DATABASE を接続先のデータベースの名前に置き換えます。

   重要

   提供された <PASSWORD> 内の@ 文字をすべてエスケープする必要があります。たとえば、p@ssword は p%40ssword にする必要があります。

この接続文字列は、--uri オプションで mongoimport するように指定されます。

--host を使用する際、Atlas クラスターがレプリカセットである場合は、レプリカセット名も取得する必要があります。例:

myAtlasRS/atlas-host1:27017,atlas-host2:27017,atlas-host3:27017

mongoimport を実行します。

Atlas Infiniteクラスターに接続します。

この手順で一括書き込み (write)操作を実行するには、mongoshを使用してクラスターに接続します。方法を学ぶには、「Atlasクラスターへの接続」を参照してください。

また、MongoDBドライバーを使用したアプリケーションコード、Atlas UI、またはクラスターに接続するその他のインターフェースから、一括書き込み (write)操作を実行することもできます。各インターフェースでの同等の操作を学ぶには、「一括書き込み (write)操作」を参照してください。

一括書き込み (write)操作 (bulk write operation) を実行します。

単一のコレクションに書き込み (write)を行うには、bulkWrite()を実行します。書き込み (write)操作の種類と一括書き込み (write)オプションについて詳しく学ぶには、bulkWrite().を参照してください。

たとえば、次のコマンドは inventory コレクションに 2 つのドキュメントを挿入します。

db.inventory.bulkWrite( [   { insertOne: { document: {      _id: ObjectId("68b1c2d3e4f5a6b7c8d9e0f1"),      item: "notebook",      qty: 50   } } },   { insertOne: { document: {      _id: ObjectId("68b1c2d3e4f5a6b7c8d9e0f2"),      item: "pencil",      qty: 100   } } }] )

1つのリクエストで複数のコレクションやデータベースに書き込み (write)を行うには、bulkWrite()を実行し、各操作の名前空間を指定します。例、次のコマンドはsales.inventoryコレクションに1つのドキュメントを挿入し、supplies.inventoryコレクションに1つのドキュメントを挿入します。

db.getMongo().bulkWrite( [   {      namespace: "sales.inventory",      name: "insertOne",      document: { item: "notebook", qty: 50 }   },   {      namespace: "supplies.inventory",      name: "insertOne",      document: { item: "pencil", qty: 100 }   }] )

デフォルトでは、一括書き込み (write) 操作は順番に実行され、最初のエラーで停止します。実行する順序を設定する方法を学ぶには、「操作の実行」を参照してください。

結果を検証します。

操作が返すカウントを検討し、各ターゲットコレクションのドキュメント数を確認します。詳細を学ぶには、出力を参照してください。

一括書き込み (write)操作のエラーを取り扱う方法を学ぶには、エラー処理を参照してください。