支持的聚合管道阶段

在此页面上

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

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

警告

stream_meta 字段只能用 $project 或 $unset 级移除。您只能通过以下定义的两个显式调用之一删除此字段：

{$project : { _stream_meta : 0 }}

{$unset : ["_stream_meta"]}

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

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

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