各Stream Processingワークスペースは、ストリーミングデータソースまたはシンクへの構成されたすべての接続を接続レジストリに保存します。このページの手順では、Atlas Stream Processing接続の作成と構成について説明します。
前提条件
接続を作成および構成するには、次のものが必要です。
Atlasプロジェクト
Atlas user
Project Owner接続レジストリを管理するためのProject Stream Processing Ownerまたは ロールを持つ注意
ロールと
Project OwnerProject Stream Processing Ownerロールの両方で、接続レジストリで接続を作成、表示、編集、削除する特権が付与されますが、Project Ownerロールではデータベース配置の作成、プロジェクトアクセスの管理などのタスクも実行できます。以降に更新します。これらのロールの違いについて詳しく学ぶには、「プロジェクト ロール」を参照してください。
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および S3 、 Azure Blob ストレージ、Google Cloud Pub/Sub 接続では、選択したネットワーク アクセス方法に関係なく、クラウドプロバイダーアクセス構成が必要です。
Blob ストレージ接続用のAzure Service Principal Access を設定するには、 「 Azure Service Principal Access の設定と管理 」を参照してください。
パブリック/サブスクライブ接続のGCPサービス アカウント アクセスを設定するには、「 Google Cloud サービス アカウント アクセスの設定と管理 」を参照してください。
注意
時系列コレクションを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 接続を削除するためのエンドポイントを提供します。