各Stream Processingワークスペースは、ストリーミングデータソースまたはシンクへの構成されたすべての接続を接続レジストリに保存します。このページの手順では、Atlas Stream Processing接続の作成と構成について説明します。
前提条件
接続を作成および構成するには、次のものが必要です。
Atlasプロジェクト
Atlas user
Project Owner接続レジストリを管理するためのProject Stream Processing Ownerまたは ロールを持つ注意
While both the
Project OwnerandProject Stream Processing Ownerroles grant the privileges to create, view, edit, and delete connections in the connection registry, theProject Ownerrole also allows users to perform tasks such as creating database deployments, managing project access, and more.これらのロールの違いについて詳しく学ぶには、「プロジェクト ロール」を参照してください。
Atlas クラスター
Considerations
Atlas Stream Processing 接続を構成するときは、ユースケースに適した接続タイプを選択していることを確認します。Atlas Stream Processing は次のプロバイダーをサポートしています。
プロバイダー（注を参照してください） | 説明 | 接続タイプ |
|---|---|---|
Kafkaブロック | イベントストリームを受信して保存し、パーティション化されたトピックに整理する構成可能なサーバー。 | Sink と Source |
Atlas クラスター | Sink と Source | |
Amazon Web ServicesS3 | Amazon Web Servicesでホストされているオブジェクトストレージコンテナ。 | 同期のみ |
Amazon Web Services Kinesis | イベントストリームを受信して保存し、さまざまな統合ツールを提供するクラウドでホストされるプラットフォーム。 | Sink と Source |
Azure BLOB ストレージ | Azureでホストされているオブジェクトストレージコンテナ。 | 同期のみ |
Google Cloud パブリック/サブスクライブ | 非同期ストリーミングをサポートするGoogle Cloudのサービス。 | 同期のみ |
HTTPS | ドキュメントが通過するたびにAPIエンドポイントを介してデータを検索するための HTTPS リクエスト 。Atlas Stream Processing はこのデータを使用して、リクエストをトリガーしたドキュメントを強化します。 | 追加ソース。は |
外部関数接続 | Atlas Stream Processing は、 Atlas Stream Processingパイプライン内のAmazon Web Services Lambdaリソースへの埋め込み呼び出しをサポートしています。これらの呼び出しは同期または非同期で実行でき、同期呼び出しからの応答をパイプラインの後続のステージに渡すことができます。 詳細については、Atlas Stream Processing 外部関数 のドキュメントを参照してください。 | トリガーする |
注意
AWS Kinesis and S3, Azure Blob Storage, and Google Cloud Pub/Sub connections require cloud provider access configuration regardless of the network access method you choose:
To set up Unified AWS Access for Kinesis and S3 connections, see Set Up Unified AWS Access.
To set up Azure Service Principal Access for Blob Storage connections, see Set Up and Manage Azure Service Principal Access.
To set up GCP Service Account Access for Pub/Sub connections, see Set Up and Manage Google Cloud Service Account Access.
注意
時系列コレクションをAtlas Stream Processingのソースとして使用することはできません。時系列コレクションは変更ストリームをサポートしていません。
Tip
詳細については、時系列コレクションの制限を参照してください。
接続レジストリへの接続の追加
各 Atlas Stream Processing 接続タイプには、異なる構成要件と手順があります。詳しくは、Atlas Stream Processing 接続の追加 を参照してください。
接続レジストリでの接続の表示
Stream Processing ワークスペースへの接続を表示するには：
Atlas CLI を使用して、指定した 1 つの stream processing ワークスペースからのすべての接続を一覧表示するには、次のコマンドを実行します。
atlas streams connections list [options]
Atlas CLI を使用して指定した 1 つのストリーム プロセシング接続の詳細を返すには、次のコマンドを実行します。
atlas streams connections describe <streamConnectionName> [options]
前のコマンドの構文とパラメーターの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続リストおよびAtlas Streams 接続の説明を参照してください。
Atlas で、プロジェクトの [Stream Processing] ページに移動します。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、接続レジストリ内の 1 つまたはすべての接続を取得するためのさまざまなエンドポイントを提供します。
mongoshを使用して利用可能なすべての接続をリストするには、sp.listConnections()メソッドを使用します。Stream Processing ワークスペースの接続レジストリ内の各接続を説明するドキュメントのリストが返されます。構文は次のとおりです。
sp.listConnections()
接続レジストリからの接続の変更
接続レジストリから接続を変更するには、次の手順に従います。
Atlas CLI を使用して指定したストリーム処理ワークスペースの 1 つの接続の詳細を変更するには、次のコマンドを実行します。
atlas streams connections update <connectionName> [options]
コマンド構文とパラメータの詳細については、Atlas CLI ドキュメントの Atlas Streams 接続の更新を参照してください。
Atlas で、プロジェクトの [Stream Processing] ページに移動します。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、Stream Processing ワークスペースを編集するためのエンドポイントを提供します。
接続レジストリからの接続の削除
接続レジストリから接続を削除するには、次の手順に従います。
Atlas CLI を使用して指定した stream processing ワークスペースから 1 つの接続を除くには、次のコマンドを実行します。
atlas streams connections delete <connectionName> [options]
コマンド構文とパラメータの詳細については、 Atlas CLIドキュメントの「 Atlas connection delete 」を参照してください。
Atlas で、プロジェクトの [Stream Processing] ページに移動します。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
Atlas Administration API は、Stream Processing ワークスペースを編集するためのエンドポイントを提供します。
接続レジストリからの接続のテスト
接続レジストリからの接続が Atlas UIで正しく機能していることを確認するには、次の手順に従います。
Atlas で、プロジェクトの [Stream Processing] ページに移動します。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Streaming Data見出しの下のStream Processingをクリックします。
Atlas Stream Processingページが表示されます。
プライベートリンク接続を一覧表示する
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 接続を削除するためのエンドポイントを提供します。