サポートされている集計パイプラインステージ

項目一覧

サポートされている集計パイプラインステージ

Atlas Stream Processing は、連続データストリームを処理するためのステージで集計パイプラインを拡張します。これらの連続的なステージは、デフォルトの mongodプロセスに組み込まれている既存の集計ステージと組み合わせることで、保存中のデータで実行できるのと同じ操作を多く実行できます。 Atlas Stream Processing パイプラインの定義は16 MB を超えることはできません。

次の表は、Atlas Stream Processing に固有の集計パイプラインステージと、Atlas Stream Processing に変更された形式で存在する集計パイプラインステージを示しています。

警告

stream_metaフィールドは、 $projectまたは$unsetステージでのみ削除できます。このフィールドは、以下に定義されている 2 つの明示的な呼び出しのいずれかを使用してのみ削除できます。

{$project : { _stream_meta : 0 }}

{$unset : ["_stream_meta"]}

注意

構文や例など、特定の演算子の詳細については、演算子のリファレンスページへのリンクをクリックしてください

集計パイプラインステージ	目的
`$source`	メッセージを消費するストリーミングデータソースを指定します。
`$validate`	ユーザー定義のスキーマに対してストリームのドキュメントを検証します。
`$https`	ストリームプロセッサ内の任意のREST APIエンドポイントに対する `curl` のような呼び出しをサポートします。
$lookup	指定されたコレクションへの左外部結合を実行して、"join" コレクションのドキュメントをフィルタリングして処理します。既存の`$lookup`ステージのこのバージョンでは、 `from`フィールドの値として接続レジストリで Atlas コレクションを指定する必要があります。
`$hoppingWindow`	ユーザー定義の期間と開始時間間隔でストリームからドキュメントをWindowsに割り当てます。
`$tumblingWindow`	ストリームからのドキュメントを、ユーザー定義の期間を持つ重複のない連続したWindowsに割り当てます。
$emit	メッセージを発行する接続レジストリ内のストリームまたは時系列コレクションを指定します。
$merge	既存の`$merge`ステージのバージョンで、 `connectionName`フィールドの値は常に接続レジストリ内のリモートコレクションの名前である必要があります。

サポートされている集計パイプラインステージ

Atlas Stream Processing は、MongoDB集計パイプラインの主要構文に対してさまざまな拡張機能を提供します。これらの拡張機能の詳細については、サポートされている集計パイプラインステージを参照してください。

集計パイプラインの特定のコアステージは、次の表に示すようにサポートが制限されているか、サポートされていません。ステージがテーブルにリストされていない場合、Atlas Stream Processing はそれをサポートします。

集計ステージ	サポートステータス
`$group`	`$tumblingWindow`または`$hoppingWindow`でのみサポートされています。
`$sort`	`$tumblingWindow`または`$hoppingWindow`でのみサポートされています。
`$limit`	`$tumblingWindow`または`$hoppingWindow`でのみサポートされています。
`$count`	`$tumblingWindow`または`$hoppingWindow`でのみサポートされています。
`$merge`	変更された構文でサポートされています。詳しくは、 `$merge`を参照してください。
`$lookup`	変更された構文でサポートされています。詳しくは、 `$lookup`を参照してください。

戻る

$convert

$source

警告

注意

サポートされている集計パイプライン ステージ

サポートされている集計パイプラインステージ