Atlas Stream Processing アーキテクチャ

階層

ストリーム プロセッサを定義すると、そのストリーム プロセッサを定義するストリーム処理ワークスペースでのみ使用可能になります。各ストリーム プロセッサは、その階層に応じて割り当てられたリソースで実行されます。Atlas Stream Processing は、ストリーム プロセッサがを実行中間のみ、ストリーム プロセッサに対して 請求を行います。

階層サイズを宣言せずにストリーム プロセッサを起動すると、Stream Processing ワークスペースの階層で実行されます。Stream Processing ワークスペースの最大階層まで、任意の階層のストリーム プロセッサを起動できます。

ワーカー（レガシー）

各ワーカーは最大 4 つの実行中のストリームプロセッサをホストできます。レガシーワーカー モデルで実行されるストリーム処理ワークスペースは、ワーカーの数に応じてユーザーに課金します。Atlas Stream Processing は、必要にプロビジョニングワーカー によってストリーム プロセッサを起動すると、ストリーム処理ワークスペースを自動的にスケールアップします。すべてのストリーム プロセッサを停止することで、ワーカーのプロビジョニングを解除できます。Atlas Stream Processing では、新しいワーカーをプロビジョニングよりも、既存のワーカーにストリーム プロセッサを割り当てることを常に優先します。

スケーリング時に、Atlas Stream Processing では現在実行中のストリーム プロセッサの数のみが考慮されます。実行されていない定義済みストリーム プロセッサはカウントされません。Stream Processing ワークスペースの階層によって、ワーカーの RAM と CPU の割り当てが決定されます。

接続レジストリ

接続レジストリには 1 つ以上の接続が保存されます。 各接続は、ストリーム プロセッサが外部サービスと交流できるようにするネットワークとセキュリティの詳細の組み合わせに名前を割り当てます。 接続では、次の動作が見られます。

• 特定の Stream Processing ワークスペースの接続レジストリで定義された接続のみが、その Stream Processing ワークスペース上のストリーミング配信するプロセッサ ホストにサービスを提供できます。

• 各接続は任意の数のストリーム プロセッサを処理できます

• 単一の接続のみが、特定のストリーム プロセッサのソースとして機能できます。

• 1 つの接続のみが、特定のストリーム プロセッサのシンクとして機能できます。

• 接続は、ソースまたはシンクのいずれかとして最初に定義されることはありません。 ストリーム プロセッサがその接続を呼び出す方法に応じて、任意の接続がどちらの機能も提供できます。

Atlas Stream Processing は、マルチテナントインフラストラクチャ上のカスタマー専用コンテナでストリーム処理ポッドを実行します。MongoDB のセキュリティおよびコンプライアンスに関する詳細は、MongoDB トラストセンターをご覧ください。

イベント時間

イベント時間は、ソースストリームがドキュメントを生成した時点、またはメッセージング システム（例:Apache Kafka）はドキュメントを受け取ります。これは、ドキュメントのタイムスタンプによって保証されます。

ネットワークレイテンシ、上流処理、およびその他の要因により、特定のドキュメントでこれらの時間間の不整合が生じるだけでなく、ドキュメントがイベント時間順からストリーム プロセッサに到達する可能性もあります。いずれの場合も、 Windows はキャプチャする予定のドキュメントを失う可能性があります。 Atlas Stream Processing は、このようなドキュメントが 遅延 しているドキュメントを考慮し、デッド レター キューに送信します（ 設定されている場合）。

イベント時間は、 Tumbling WindowsとホスティングWindowsでサポートされている boundaryフィールドの構成可能なオプションです。

プロセシング時間

処理時間とは、ストリーム プロセッサがドキュメントを使用する時間のことであり、ストリーム プロセッサをホストするシステムのクロックによって確認されます。

プロセシング タイムは、Tumbling WindowsとホスティングWindowsでサポートされている boundaryフィールドの構成可能なオプションです。これにより、サーバーのウォール クロック時間に基づいてデータを蓄積するウィンドウの種類のパイプラインを作成できます。イベント時間Windowsとは対照的に、プロセシング時間Windows は、ストリーム プロセッサに到達したときにサーバーのウォール クロック時間に基づいて各イベントにタイムスタンプを割り当てます。

ドキュメント タイムスタンプとウィンドウ境界タイムスタンプは UTC です。ウィンドウを構成するときに、 idleTimeout またはprocessingTime allowレイテンシのオプションを指定することはできません。