Atlas Stream Processing アーキテクチャ

労働者

ストリーム プロセッサを定義すると、それが定義されているストリーム プロセシング インスタンスでのみ使用可能になります。 各ワーカーは最大 4 つの実行中のストリーム プロセッサをホストできます。 Atlas Stream Processing は、ストリーム プロセッサを起動すると、必要に応じて ワーカー をプロビジョニングすることで、ストリーム プロセシング インスタンスを自動的にスケールアップします。 すべてのストリーム プロセッサを停止することで、ワーカーのプロビジョニングを解除できます。 Atlas Stream Processing では、新しいワーカーをプロビジョニングするよりも、既存のワーカーにストリーム プロセッサを割り当てることを常に優先します。

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

接続レジストリ

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

• 特定のストリーム プロセシング インスタンスの接続レジストリで定義された接続のみが、そのストリーム プロセシング インスタンスでホストされているストリーム プロセッサを処理できます。

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

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

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

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

Atlas Stream Processing は、マルチテナント インフラストラクチャ上の専用のカスタマー コンテナでストリーム プロセシング ワーカーを実行します。 MongoDB のセキュリティとコンプライアンスの詳細については、 MongoDB トラスト センター を参照してください。

イベント時間

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

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

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

プロセシング時間

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

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

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