各ストリーム プロセシング ワークスペースは、ストリーミングデータソースまたは シンクへの構成済みのすべての接続を 接続レジストリ に保存します。このページの手順では、Atlas Stream Processing 接続の作成と構成について説明します。
前提条件
接続を作成および構成するには、次のものが必要です。
Atlas プロジェクト
接続レジストリを管理するための
Project Stream Processing Owner{2Atlas userProject Ownerまたは ロールを持つ注意
Project OwnerロールとProject Stream Processing Ownerロールの両方は、接続レジストリで接続を作成、表示、編集、削除する権限を付与しますが、Project Ownerロールは、データベース配置の作成、プロジェクトアクセスの管理などのタスクを実行することもできます。これらのロールの違いについて詳しく学ぶには、「プロジェクト ロール」を参照してください。
Atlas クラスター
Considerations
Atlas Stream Processing 接続を構成するときは、ユースケースに適した接続タイプを選択していることを確認します。Atlas Stream Processing は次のプロバイダーをサポートしています。
プロバイダー（ 注を参照してください） | 説明 | 接続タイプ |
|---|---|---|
Kafkaブロック | イベントストリームを受信して保存し、パーティション化されたトピックに整理する構成可能なサーバー。 | Sink と Source |
Atlas クラスター | 永続的ストレージとイベント駆動型 Change Streams の両方を提供するクラウドでホストされるMongoDBサーバー。 | Sink と Source |
Amazon Web Services S3 | Amazon Web Servicesでホストされているオブジェクトストレージコンテナ。 | 同期のみ |
AWS Kinesis | 同期のみ | |
HTTPS | ドキュメントが通過するたびにAPIエンドポイントを介してデータを検索するための HTTPS リクエスト 。Atlas Stream Processing はこのデータを使用して、リクエストをトリガーしたドキュメントを強化します。 | 追加ソース。は |
外部関数接続 | Atlas Stream Processing は、 Atlas Stream Processingパイプライン内のAmazon Web Services Lambdaリソースへの埋め込み呼び出しをサポートしています。これらの呼び出しは同期または非同期で実行でき、同期呼び出しからの応答をパイプラインの後続のステージに渡すことができます。 詳細については、Atlas Stream Processing 外部関数 のドキュメントを参照してください。 | トリガーする |
注意
時系列コレクションを Atlas Stream Processing のソースとして使用することはできません。時系列コレクションは変更ストリームをサポートしていません。
Tip
詳細については「 時系列コレクションの制限 」を参照してください。
接続レジストリへの接続の追加
各 Atlas Stream Processing 接続タイプには、異なる構成要件と手順があります。詳しくは、Atlas Stream Processing 接続の追加 を参照してください。
接続レジストリでの接続の表示
Atlas ストリーム処理ワークスペースへの接続を表示するには:
Atlas CLI を使用して、指定した 1 つのストリーム処理ワークスペースからのすべての接続を一覧表示するには、次のコマンドを実行します。
atlas streams connections list [options]
Atlas CLI を使用して指定した 1 つのストリーム プロセシング接続の詳細を返すには、次のコマンドを実行します。
atlas streams connections describe <streamConnectionName> [options]
前のコマンドの構文とパラメーターの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続リストおよびAtlas Streams 接続の説明を参照してください。
Atlas Atlasで、プロジェクトの {0 ページにGoします。GoStream Processing
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、接続レジストリ内の 1 つまたはすべての接続を取得するためのさまざまなエンドポイントを提供します。
mongosh を使用して利用可能なすべての接続を一覧表示するには、sp.listConnections() メソッドを使用します。これにより、ストリーム処理ワークスペースの接続レジストリ内の各接続を説明するドキュメントのリストが返されます。構文は次のとおりです。
sp.listConnections()
接続レジストリからの接続の変更
接続レジストリから接続を変更するには、次の手順に従います。
Atlas CLI を使用して指定したストリーム処理ワークスペースの 1 つの接続の詳細を変更するには、次のコマンドを実行します。
atlas streams connections update <connectionName> [options]
コマンド構文とパラメータの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続の更新を参照してください。
AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、ストリーム処理ワークスペースを編集するためのエンドポイントを提供します。
接続レジストリからの接続の削除
接続レジストリから接続を削除するには、次の手順に従います。
Atlas CLI を使用して指定したストリーム処理ワークスペースから 1 つの接続を削除するには、次のコマンドを実行します。
atlas streams connections delete <connectionName> [options]
コマンド構文とパラメータの詳細については、 Atlas CLIドキュメントの「 Atlas connection delete 」を参照してください。
AtlasGoStream ProcessingAtlas で、プロジェクトの ページにGoします。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、ストリーム処理ワークスペースを編集するためのエンドポイントを提供します。
プライベートリンク接続を一覧表示する
Atlas Administration API は、指定されたプロジェクト内の Atlas Stream Processing 用に構成されたすべての Private Link 接続を表示するためのエンドポイントを提供します。
1 つのプライベート リンク接続を表示
Atlas Administration API は、指定されたプロジェクト内の Atlas Stream Processing 用に構成された 1 つの Private Link 接続の詳細を表示するためのエンドポイントを提供します。
プライベート リンク接続の削除
Atlas Administration API は、指定されたプロジェクト内で Atlas Stream Processing 用に構成された Private Link 接続を削除するためのエンドポイントを提供します。