支持的聚合管道阶段

在此页面上

Atlas Stream Processing 通过处理连续数据流的阶段扩展了聚合管道。这些阶段与内置于默认 mongod进程的现有聚合阶段相结合，使您能够对连续数据执行许多与对静态数据执行相同的操作。 Atlas Stream Processing 管道定义不能超过16 MB。

下表列出了 Atlas Stream Processing 特有的聚合管道阶段，以及以修改后的形式存在于 Atlas Stream Processing 中的聚合管道阶段。

注意

有关特定操作符（包括事务语法和示例）的详细信息，请单击该操作符的参考页面链接。

聚合管道阶段	用途
`$source`	指定要从中使用消息的流数据源。
`$validate`	根据用户定义的模式验证流的文档。
`$https`	支持在流处理器中对任意 REST API 终结点进行类似 `curl` 的调用。
$lookup	对指定集合执行左外连接，以筛选“已连接”集合中的文档进行处理。现有`$lookup`阶段的这一版本要求将连接注册表中的 Atlas 集合指定为 `from` 字段的值。
`$hoppingWindow`	将文档从流分配到具有用户定义的持续时间和开始时间间隔的窗口。
`$tumblingWindow`	将文档从流分配到具有用户定义的持续时间的不重叠的连续窗口。
$emit	指定连接注册表中要向其发出消息的流或时间序列集合。
$merge	现有`$merge`阶段的一个版本，其中`connectionName`字段的值必须始终是连接注册表中远程collection的名称。
$sessionWindow	在输入流中的每个活动“会话”上运行管道。根据每个文档的分区和时间戳，为每个文档分配一个会话窗口。

Atlas Stream Processing 为核心 MongoDB聚合管道语法提供了许多扩展。要了解有关这些扩展的更多信息，请参阅支持的聚合管道阶段。

某些核心聚合管道阶段仅在嵌套在其他管道阶段时才受支持。下表显示了哪些聚合管道阶段支持在主管管道中使用，或者嵌套在指定的聚合管道阶段中。

聚合阶段	主管道支持	在 `$tumblingWindow` 和 `$hoppingWindow` 中受支持	在 `$https` 和 `$externalFunction` 中受支持
`$addFields`	√	√	√
`$project`	√	√	√
`$replaceRoot`	√	√	√
`$set`	√	√	√
`$redact`	√	√
`$match`	√	√
`$replaceWith`	√	√
`$unset`	√	√
`$unwind`	√	√
`$validate`	√	√
`$https`	√	√
`$externalFunction`	√	√
`$lookup` [1]	√	√
`$merge` [1]	√
`$tumblingWindow`	√
`$hoppingWindow`	√
$emit	√
`$group`		√
`$sort`		√
`$count`		√
`$limit`		√

[1]	(1, 2) 支持使用修改后的语法。

后退

$createUUID

来年

$source