对于 AI 代理:可在 https://www.mongodb.com/zh-cn/docs/llms.txt 获取文档索引—通过在任何 URL 路径后添加 .md 可获取所有页面的 Markdown 版本。
Docs 菜单

sp.processor.start()(mongosh方法)

sp.processor.start()

在当前 流处理工作区 上启动已命名的 流处理器 。

只有在连接到流处理工作区时才能调用此命令。

此命令需要mongosh版本 ≥ 2.0 。

Atlas Stream Processing 工作区支持此方法。

sp.processor.start()方法采用以下语法:

sp.processor.start(
{
<options>
}
)

sp.processor.start() 采用这些字段:

字段
类型
必要性
说明

startAfter

token

可选的

startAtOperationTime

timestamp

可选的

tier

字符串

Optional

Atlas Stream Processing将处理器分配到的层级。如果您未声明此选项,Atlas Stream Processing 会将处理器分配给流处理工作区的层级。必须是以下之一:

  • SP2

  • SP5

  • SP10

  • SP30

  • SP50

要学习;了解更多信息,请参阅层级。

autoscaling

对象

Optional

autoscaling.enabled

布尔

可选的

打开或关闭自动扩展。设立autoscaling 时为必填项。

autoscaling.minTier

字符串

Optional

处理器可以扩展到的最低层级。如果您不指定此字段, Atlas Stream Processing将使用流处理工作区默认层级和启动处理器的层级中较低的一个。

autoscaling.maxTier

字符串

Optional

处理器可以扩展到的最高层级。如果您不指定此字段, Atlas Stream Processing将使用流处理工作区的最大层级大小。

clearCheckpoints

布尔

Optional

指定此启动请求是否跳过检查点恢复。当设立为 true 时,处理器启动时不恢复检查点。默认下,此字段为 false

resumeFromCheckpoint

布尔

Optional

指定处理器启动时是否从最近的检查点恢复。默认下,该字段为 true,处理器会从最近的检查点恢复。

sp.processor.start() 在当前流处理工作区上启动已命名的流处理器。流处理器必须处于 STOPPED 省。如果您为不是 STOPPED 的流处理器调用 sp.processor.start()mongosh 将返回错误。

运行sp.processor.start() 的用户必须具有atlasAdmin角色。

以下示例启动一个名为solarDemo的流处理器。

sp.solarDemo.start()