用于 Stream Processing 的聚合管道阶段

$source

指定要从中使用消息的流数据源。

$validate

根据用户定义的模式验证流的文档。

$https

支持在流处理器中对任意 REST API 终结点进行类似 curl 的调用。

$lookup

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

This version of the existing $lookup stage requires that you specify a Atlas collection in the Connection Registry as the value for the from field.

$ skippingWindow

将文档从流分配到具有用户定义的持续时间和开始时间间隔的窗口。

$tumblingWindow

将文档从流分配到具有用户定义的持续时间的不重叠的连续窗口。

$sessionWindow

在输入流中对每个活动“会话”运行管道。每个文档会根据其分区和时间戳被分配到一个会话窗口。

$setStreamMeta

在来自输入流的文档上设置元数据字段。此元数据字段可用于执行动态操作，例如在不更改文档正文内容的情况下对文档执行接收器路由。

$cachedLookup

使用带生存时间的缓存执行查找，以减少对联接集合的重复读取。

$externalFunction

在管道内调用 AWS Lambda 函数，可选地将结果传递到下游阶段。

$throttle

限制流处理器向下游阶段传递数据的速率，以字节或每秒消息数为单位。

$emit

指定连接注册表中要向其发出消息的流或时间序列集合。

$merge

现有$merge 阶段 (Atlas Data Federation)阶段的一个版本，其中connectionName字段的值必须始终是连接注册表中远程集合的名称。

$vectorSearch

查询连接注册表中集合上的 MongoDB 向量搜索索引，并将结果附加到每个流媒体文档。