接続レジストリの管理

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[Connection Registry] に移動します。

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

Connection Registry タブを選択します。

接続を変更します。

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

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

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

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

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

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

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

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

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

[Connection Registry] に移動します。

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

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

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

接続を削除します。

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

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

Confluent クラスターを構成します。

Atlasプロジェクトからの着信接続を受け入れるように Confluent クラスターを構成する必要があります。

1. グループとリージョンの Atlas Administration APIエンドポイントの Return Account IDとVPC IDを呼び出します。awsAccountId の値に注目してください。これは後の手順で必要になります。

2. Confluent アカウントで、接続するクラスターに移動します。クラスター ネットワーク インターフェースで、クラスター ネットワークの詳細に移動します。

3. プライベートリンクアクセスの追加

   Confluent専有クラスターの場合は、選択した名前を指定します。 AWSアカウント番号には、前述の awsAccountIdフィールドの値を指定します。

   注意

   この手順は、Confluent サーバーレス クラスターでは必要ありません。

クラウドプロバイダーへの接続をリクエストします。

Atlas Administration APIは、Atlas Stream Processing 用に構成された Private Link 接続をリクエストするためのエンドポイントを提供します。

1 つのプライベート リンクを作成

AWS Private Link 接続の場合、次のキーと値のペアを設定する必要があります。

これらの値は、Confluent クラスターのネットワークの詳細で確認できます。

次の例のコマンドは、Confluent クラスターへの接続をリクエストし、一般的な応答を示しています。

curl --location
'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections'
\
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{ "vendor": "Confluent", "provider": "AWS",
  "region": "us_east_1", "serviceEndpointId":
  "com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9",
  "dnsDomain": "sample.us-east-1.aws.confluent.cloud",
  "dnsSubDomain: [
    "use1-az1.sample.us-east-1.aws.confluent.cloud",
    "use1-az2.sample.us-east-1.aws.confluent.cloud",
    "use1-az4.sample.us-east-1.aws.confluent.cloud"
  ]
}'

{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.us-east-1.aws.confluent.cloud.","vendor":"Confluent","provider":"AWS","region":"us_east_1","serviceEndpointId":"com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9"}

リクエストを送信した後、レスポンス本文の _idフィールドの値に注意します。これは後の手順で必要になります。

Confluent にインターフェイスエンドポイントIDを指定します。

すべてのプライベートリンク接続を返す エンドポイントを呼び出します。interfaceEndpointId の値に注目してください。

Confluent アカウントで、接続するクラスターに移動します。クラスター ネットワーク インターフェースで、クラスター ネットワークの詳細に移動します。アクセス ポイント インターフェイスに移動し、新しい アクセス点を追加します。 Confluent からインターフェイスエンドポイントの入力を求められたら、以前にメモした interfaceEndpointId の値を指定します。

Atlas 側の接続を作成します。

次のキーと値のペアを使用して接続を追加します。

必要に応じて、他のすべての値を設定します。

次の例のコマンドは、Atlas でApache Kafka接続を作成します。

curl --location
'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections'
\ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "name": "confluent_demo", "bootstrapServers": "slr-ntgrbn.sample.us-east-1.aws.confluent.cloud:9092", "security": { "protocol": "SASL_SSL" }, "authentication": { "mechanism": "PLAIN", "password": "apiSecretDemo", "username": "apiUserDemo" }, "type": "Kafka", "networking": { "access": { "type": "PRIVATE_LINK", "connectionId": "38972b0cbe9c2aa40a30a246" } } }'

クラウドプロバイダーへの接続をリクエストします。

Atlas Administration APIは、Atlas Stream Processing 用に構成された Private Link 接続をリクエストするためのエンドポイントを提供します。

1 つのプライベート リンクを作成

Azure Private Link 接続の場合は、次のキーと値のペアを設定する必要があります。

curl --location
'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections'
\
--digest \
--user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \
--header 'Content-Type: application/json' \
--header 'Accept: application/vnd.atlas.2023-02-01+json' \
--data '{ "provider": "AZURE", "region": "US_EAST_2", "serviceEndpointId": "/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample", "dnsDomain": "sample.servicebus.windows.net" }'

{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.servicebus.windows.net","provider":"AZURE","region":"US_EAST_2","serviceEndpointId":"/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample"}

リクエストを送信した後、レスポンス本文の _idフィールドの値に注意します。これは後の手順で必要になります。

クラウドプロバイダーのアカウント内で要求された接続を受け入れます。

Azureへの Private Link 接続には、 Event Hub ネットワーク ページに移動し、Private endpoint connections タブを選択します。接続のテーブルで、新しくリクエストされた接続を識別し、承認します。

Atlas 側の接続を作成します。

次のキーと値のペアを使用して接続を追加します。

必要に応じて、他のすべての値を設定します。

次の例のコマンドは、Atlas でApache Kafka接続を作成します。

curl --location
'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections'
\ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "name": "eventhubpl33333", "bootstrapServers": "sample.servicebus.windows.net:9093", "security": { "protocol": "SASL_SSL" }, "authentication": { "mechanism": "PLAIN", "password": "Endpoint=sb://sample.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=Irlo3OoRkc27T3ZoGOlbhEOqXQRXzb12+Q2hNXm0lc=", "username": "$ConnectionString" }, "type": "Kafka", "networking": { "access": { "type": "PRIVATE_LINK", "connectionId": "38972b0cbe9c2aa40a30a246" } } }'