Docs Menu
Docs Home
/
MongoDB Atlas
/
Atlas Stream Processing

接続レジストリの管理

項目一覧

  • 前提条件
  • 接続レジストリでの接続の表示
  • 接続レジストリへの接続の追加
  • 接続レジストリからの接続の変更
  • 接続レジストリからの接続の削除

各ストリーム プロセシング インスタンスは、ストリーミング データ ソースまたは シンクへの構成済みのすべての接続を 接続レジストリ に保存します。 このページの手順では、Atlas Stream Processing 接続の作成と構成について説明します。

前提条件

接続を作成および構成するには、次のものが必要です。

  • Atlas プロジェクト

  • 接続レジストリを管理するためのProject Stream Processing Owner {2Atlas user Project Ownerまたは ロールを持つ

    注意

    Project Ownerロールでは、データベース配置の作成、プロジェクト アクセスとプロジェクト設定の管理、IP アクセス リスト エントリの管理などを行うことができます。

    Project Stream Processing Ownerロールにより、ストリーム プロセシング インスタンスの表示、作成、削除、編集などの Atlas Stream Processing アクションや、接続レジストリ内の接続の表示、追加、変更、削除などの Atlas Stream Processing アクションが可能になります。

    2 つのロールの違いの詳細については、「プロジェクト ロール」を参照してください。

  • Atlas クラスター

接続レジストリでの接続の表示

Atlas Stream Processing インスタンスへの接続を表示するには：

Atlas CLI を使用して指定した 1 つのストリーム プロセシング インスタンスからのすべての接続を一覧表示するには、次のコマンドを実行します。

atlas streams connections list [options]

Atlas CLI を使用して指定した 1 つのストリーム プロセシング接続の詳細を返すには、次のコマンドを実行します。

atlas streams connections describe <streamConnectionName> [options]

前のコマンドの構文とパラメータの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続リストとAtlas Streams 接続の説明 を参照してください。

Tip

参照: 関連リンク

1

Atlas Atlasで、プロジェクトの {0 ページにGoします。GoStream Processing

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

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

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

    Atlas Stream Processingページが表示されます。

2

Connection Registryページに移動します。

  1. 表示する接続レジストリを含むストリーム プロセシング インスタンスの概要パネルを見つけます。

  2. [Configure] をクリックします。

  3. Connection Registry タブを選択します。

Atlas Stream Processing は、 インスタンス接続レジストリで利用可能なすべての接続を表示します。

Atlas Administration API は、接続レジストリ内の 1 つまたはすべての接続を取得するためのさまざまなエンドポイントを提供します。

接続レジストリでの 1 つの接続の表示

接続レジストリでのすべての接続の一覧表示

mongoshを使用して利用可能なすべての接続を一覧表示するには、 sp.listConnections()メソッドを使用します。 ストリーム プロセシング インスタンスの接続レジストリ内の各接続を説明するドキュメントのリストが返されます。 構文は次のとおりです。

sp.listConnections()

接続レジストリへの接続の追加

Atlas Stream Processing は次の接続タイプをサポートしています。

各タイプには異なる構成要件があります。

Apache Kafka 接続の追加

重要

Atlas Stream Processing の VPC ピアリングは現在プライベートプレビュー段階です。 詳しくは、アカウント チームにお問い合わせください。

Atlas Stream Processing インスタンスに Kafka 接続を追加するには、次の手順に従います。

Atlas CLI を使用して、指定したストリーム プロセシング インスタンスの 1 つの接続を作成するには、次のコマンドを実行します。

atlas streams connections create [connectionName] [options]

コマンド構文とパラメーターの詳細については、 Atlas CLIドキュメントの「 Atlas streams connection create 」を参照してください。

Tip

参照: 関連リンク

Atlas CLI を使用してストリーム プロセシング インスタンスを作成する場合は、新しい接続のパラメーターを定義するための.json構成ファイルを提供する必要があります。 このファイルの形式は、定義する接続のタイプによって異なります。

Apache Kafka の場合 接続には、次の構文を持つ構成ファイルを指定します。

{
  "name": "<name>",
  "type": "Kafka",
  "bootstrapServers": "<address:port>, ...",
  "security": {
    "protocol": "<protocol>"
  },
  "authentication": {
    "mechanism": "<auth-mechanism>",
    "username": "<username>",
    "password": "<password>"
  }
}
1

AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。

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

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

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

    Atlas Stream Processingページが表示されます。

2

[Connection Registry] に移動します。

  1. 変更するストリーム プロセシング インスタンスの概要パネルを見つけ、 Configureをクリックします。

  2. Connection Registry タブを選択します。

3

をクリックします。<a class=\" \" href=\" \" title=\" \"><svg xmlns=\" \" width=\" \" height=\" \" fill=\" \" viewbox=\" \" class=\" \" role=\" \" aria-label=\" \"><path fill=\" \" d=\" \"> <path fill=\" \" d=\" \">+ Add connection

4

新しい接続を追加します。

  1. Kafka接続を選択します。

  2. Connection Nameを指定します。 各接続名は、ストリーム プロセシング インスタンス内で一意である必要があります。 これは、Atlas Stream Processing の集計で接続を参照するために使用される名前です。

  3. Network Accessタイプを選択します。 Atlas Stream Processing はPublic IPまたはVPC Peering接続をサポートしています。

    [ Public IP ] ボタンをクリックします。 このネットワーク アクセス タイプでは、それ以上の設定は必要ありません。

    1. VPC Peeringボタンをクリックします。

    2. Enable VPC Peering をオンに切り替えます。Atlas Stream Processing は、構成された接続から適切な VPC ピアリング接続を自動的に選択します。

      VPCピアリング接続がない場合は、「Atlas ネットワークピアリング接続の構成 」を参照してください。

  4. 1 つ以上の ブートストラップ サーバー の IP アドレスを指定 Apache Kafka 用 システム参照してください。

  5. ドロップダウン メニューからSecurity Protocol Method ] を選択します。

    Atlas Stream Processing はSASL_PLAINTEXTまたはSASL_SSLをサポートしています。

    SASL_PLAINTEXT は VPC ピアリングと互換性がありません。 VPC ピアリングを使用するには、 SASL_SSLメソッドを選択する必要があります。

    1. ドロップダウン メニューからSASL Mechanism ] を選択します。

      Atlas Stream Processing は以下をサポートします。

      • PLAIN

      • SCRAM-SHA-256

      • SCRAM-SHA-512

    2. 認証にはUsernameを指定します。

    3. 認証用パスワードを入力します。

    4. [Add connection] をクリックします。

    1. ドロップダウン メニューからSASL Mechanism ] を選択します。

      Atlas Stream Processing は以下をサポートします。

      • PLAIN

      • SCRAM-SHA-256

      • SCRAM-SHA-512

    2. Uploadをクリックして をアップロードしますCertificate Authority PEM file

    3. 認証にはUsernameを指定します。

    4. 認証用パスワードを入力します。

    5. [Add connection] をクリックします。

Atlas Administration API は、接続レジストリに接続を追加するためのエンドポイントを提供します。

接続レジストリへの接続の追加

重要

Apache Kafka などの外部接続を追加した後 クラスターが接続レジストリに追加されている場合は、その外部接続用のアクセス リストに Atlas IP アドレスを追加する必要があります。詳細については、 「 Atlas Control Plane へのアクセスまたは Atlas Control Plane からのアクセス許可 」を参照してください。

Atlas 接続の追加

重要

Atlas Stream Processing の VPC ピアリングは現在プライベートプレビュー段階です。 詳しくは、アカウント チームにお問い合わせください。

Atlas データベース接続をストリーム プロセシング インスタンスに追加するには、次の手順に従います。

Atlas CLI を使用して、指定したストリーム プロセシング インスタンスの 1 つの接続を作成するには、次のコマンドを実行します。

atlas streams connections create [connectionName] [options]

コマンド構文とパラメーターの詳細については、 Atlas CLIドキュメントの「 Atlas streams connection create 」を参照してください。

Tip

参照: 関連リンク

Atlas CLI を使用してストリーム プロセシング インスタンスを作成する場合は、新しい接続のパラメーターを定義するための.json構成ファイルを提供する必要があります。 このファイルの形式は、定義する接続のタイプによって異なります。

Atlas データベース接続には、次の構文を含む構成ファイルを提供します。

{
  "name": "<name>",
  "type": "Cluster",
  "clusterName": "<clusterName>"
}
1

AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。

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

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

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

    Atlas Stream Processingページが表示されます。

2

[Connection Registry] に移動します。

  1. 変更するストリーム プロセシング インスタンスの概要パネルを見つけ、 Configureをクリックします。

  2. Connection Registry タブを選択します。

3

をクリックします。<a class=\" \" href=\" \" title=\" \"><svg xmlns=\" \" width=\" \" height=\" \" fill=\" \" viewbox=\" \" class=\" \" role=\" \" aria-label=\" \"><path fill=\" \" d=\" \"> <path fill=\" \" d=\" \">+ Add connection

4

新しい接続を追加します。

Atlas変更ストリームへの新しい接続を作成するには

  1. Atlas Database接続を選択します。

  2. Connection Nameを指定します。 各接続名は、ストリーム プロセシング インスタンス内で一意である必要があります。 これは、Atlas Stream Processing の集計で接続を参照するために使用される名前です。

  3. ドロップダウン メニューからAtlas Cluster ] を選択します。 Atlas Stream Processing は専用階層クラスターでのみ利用できます。

  4. [Add connection] をクリックします。

Atlas Administration API は、接続レジストリに接続を追加するためのエンドポイントを提供します。

接続レジストリへの接続の追加

接続レジストリからの接続の変更

接続レジストリから接続を変更するには、次の手順に従います。

Atlas CLI を使用して指定したストリーム プロセシング インスタンスの 1 つの接続の詳細を変更するには、次のコマンドを実行します。

atlas streams connections update <connectionName> [options]

コマンド構文とパラメータの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続の更新を参照してください。

Tip

参照: 関連リンク

1

AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。

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

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

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

    Atlas Stream Processingページが表示されます。

2

[Connection Registry] に移動します。

変更する接続レジストリを含むストリーム プロセシング インスタンスの概要パネルを見つけ、右上の [ Configure ] をクリックします。

3

Connection Registryタブを選択します。

4

接続を変更します。

  1. テーブル内の変更する接続については、 Actions列の鉛筆アイコンをクリックします。

    接続が現在ストリーム プロセッサによって使用されていない場合にのみ、接続を編集できます。 使用中の接続を編集する場合は、まず接続を使用するすべてのストリーム プロセッサを停止します。

  2. 変更したいフィールドを変更します。

  3. [Save changes] をクリックします。

Atlas Administration API は、ストリーム プロセシング インスタンスを編集するためのエンドポイントを提供します。

1 つのストリーム インスタンスを削除

接続レジストリからの接続の削除

接続レジストリから接続を削除するには、次の手順に従います。

Atlas CLI を使用して指定したストリーム プロセシング インスタンスから 1 つの接続を削除するには、次のコマンドを実行します。

atlas streams connections delete <connectionName> [options]

コマンド構文とパラメータの詳細については、 Atlas CLIドキュメントの「 Atlas connection delete 」を参照してください。

Tip

参照: 関連リンク

1

AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。

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

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

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

    Atlas Stream Processingページが表示されます。

2

[Connection Registry] に移動します。

  1. 変更する接続レジストリを含むストリーム プロセシング インスタンスの概要パネルを見つけます

  2. 右上の [ Configureをクリックします。

  3. Connection Registry タブを選択します。

3

接続を削除します。

  1. テーブル内の変更する接続について、そのエントリのActions列にあるゴミ箱アイコンをクリックします。

  2. プロンプトが表示されたら、[ Delete ] をクリックします。

Atlas Administration API は、ストリーム プロセシング インスタンスを編集するためのエンドポイントを提供します。

1 つのストリーム インスタンスを削除

戻る

Atlas Stream Processing インスタンスの管理

次へ

ストリーム プロセッサの管理