Docs 菜单
Docs 主页
/
MongoDB Atlas
/

支持的聚合管道阶段

在此页面上

  • 支持的聚合管道阶段

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
指定要从中使用消息的流数据源。
根据用户定义的模式验证流的文档。

对指定集合执行左外连接,以筛选“已连接”集合中的文档进行处理。

此版本的现有$lookup阶段要求您在连接注册表中指定 Atlas 集合作为from字段的值。

将文档从流分配到具有用户定义的持续时间和开始时间间隔的窗口
将文档从流分配到具有用户定义的持续时间的不重叠的连续窗口
指定连接注册表中要向其发出消息的流或时间序列集合。
现有$merge阶段的一个版本,其中connectionName字段的值必须始终是连接注册表中远程collection的名称。

您还可以使用流数据管道中所有mongod进程支持的以下阶段:

聚合管道阶段
使用条件
不限地点
不限地点
不限地点
不限地点
不限地点
不限地点
不限地点
不限地点
不限地点
仅在$hoppingWindow$tumblingWindow阶段内。
仅在$hoppingWindow$tumblingWindow阶段内。
仅在$hoppingWindow$tumblingWindow阶段内。
仅在$hoppingWindow$tumblingWindow阶段内。

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

某些核心聚合管道阶段的支持有限或不受支持,如下表所示。 如果表中未列出某个阶段,则 Atlas Stream Processing 支持该阶段。

聚合阶段
支持状态
通过修改后的语法提供支持。 有关更多信息,请参阅$merge
通过修改后的语法提供支持。 有关更多信息,请参阅$lookup

后退

托管流处理器