CDC 用にセルフマネージド MongoDB データベースを構成する

Datastream を使用すると、セルフマネージド MongoDB レプリカセットまたはシャーディングされたクラスタから、BigQuery や Cloud Storage などのサポートされている宛先に変更データ キャプチャ（CDC）の更新をストリーミングできます。ソースを準備するには、デプロイの admin データベースに読み取り権限を持つ Datastream ユーザーを作成します。

レプリカセット

MongoDB レプリカセットのデプロイについては、MongoDB ドキュメントの自己管理型レプリカセットの配置をご覧ください。

セルフマネージドの MongoDB レプリカセットで使用するように Datastream を構成するには、次の手順に従ってください。

  1. MongoDB シェルをインストールします。MongoDB Shell のインストール方法については、mongosh をインストールするをご覧ください。
  2. ターミナル ウィンドウを開き、mongosh コマンドを実行して、レプリカセットまたはプライマリ ノードに接続します。

  3. admin データベースに Datastream のユーザーを作成します。

    use admin
db.createUser({
  user: "USERNAME",
  pwd: "PASSWORD",
  roles: [ "readAnyDatabase", {role: "read", db: "admin"} ]
})

    USERNAME と PASSWORD は、任意のユーザー名とパスワードに置き換えます。

シャーディングされたクラスタ

シャーディングされたクラスタのデプロイについては、MongoDB ドキュメントのシャーディングされたクラスターの配置をご覧ください。

セルフマネージドのシャーディングされた MongoDB クラスタで使用するように Datastream を構成するには、次の手順に従ってください。

  1. MongoDB シェルをインストールします。MongoDB Shell のインストール方法については、mongosh をインストールするをご覧ください。
  2. ターミナル ウィンドウを開き、mongosh コマンドを実行して、シャーディングされた MongoDB クラスタに接続します。

  3. すべてのプライマリ シャードノードと mongos クエリ ルーターに Datastream ユーザーを作成します。

    use admin
db.createUser({
   user: "USERNAME",
   pwd: "PASSWORD",
   roles: [ "readAnyDatabase" ]
})

    USERNAME と PASSWORD は、ユーザー名とパスワードに置き換えます。任意のユーザー名とパスワードを選択できますが、すべてのプライマリ シャード ノードと mongos クエリルーターで同一のユーザー名とパスワードを使用する必要があります。

  4. mongos クエリルーターに接続されているシャードを調べるには、次のコマンドを実行します。

    db.adminCommand({ listShards: 1 })