各ストリーム プロセシング インスタンスは、ストリーミング データ ソースまたは シンクへの構成済みのすべての接続を 接続レジストリ に保存します。 このページの手順では、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でホストされているオブジェクトストレージコンテナ。 | 同期のみ |
HTTPS | ドキュメントが通過するたびにAPIエンドポイントを介してデータを検索するための HTTPS リクエスト 。Atlas Stream Processing はこのデータを使用して、リクエストをトリガーしたドキュメントを強化します。 | 追加ソース。は |
外部関数接続 | Atlas Stream Processing は、 Atlas Stream Processingパイプライン内のAmazon Web Services Lambda リソースへの埋め込み呼び出しをサポートしています。これらの呼び出しは同期または非同期で実行でき、同期呼び出しからの応答をパイプラインの後続のステージに渡すことができます。 詳細については、Atlas Stream Processing 外部関数 のドキュメントを参照してください。 | トリガーする |
接続レジストリへの接続の追加
各 Atlas Stream Processing 接続タイプには、異なる構成要件と手順があります。詳しくは、Atlas Stream Processing 接続の追加 を参照してください。
接続レジストリでの接続の表示
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 接続の説明を参照してください。
Atlas Atlasで、プロジェクトの {0 ページにGoします。GoStream Processing
警告: ナビゲーションの改善が進行中
現在、新しく改善されたナビゲーション エクスペリエンスを展開しています。次の手順が Atlas UIのビューと一致しない場合は、プレビュー ドキュメントを参照してください。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Services見出しの下の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します。
警告: ナビゲーションの改善が進行中
現在、新しく改善されたナビゲーション エクスペリエンスを展開しています。次の手順が Atlas UIのビューと一致しない場合は、プレビュー ドキュメントを参照してください。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Services見出しの下の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します。
警告: ナビゲーションの改善が進行中
現在、新しく改善されたナビゲーション エクスペリエンスを展開しています。次の手順が Atlas UIのビューと一致しない場合は、プレビュー ドキュメントを参照してください。
まだ表示されていない場合は、プロジェクトを含む組織をナビゲーション バーの Organizations メニューで選択します。
まだ表示されていない場合は、ナビゲーション バーの Projects メニューからプロジェクトを選択します。
サイドバーで、 Services見出しの下の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 接続を削除するためのエンドポイントを提供します。