定义
sp.processor.start()在当前 流处理工作区 上启动已命名的 流处理器 。
只有在连接到流处理工作区时才能调用此命令。
此命令需要
mongosh版本 ≥ 2.0 。
兼容性
Atlas Stream Processing 工作区支持此方法。
语法
sp.processor.start()方法采用以下语法:
sp.processor.start( { <options> } )
命令字段
sp.processor.start() 采用这些字段:
字段 | 类型 | 必要性 | 说明 |
|---|---|---|---|
| token | 可选的 | |
| timestamp | 可选的 | |
| 字符串 | Optional | Atlas Stream Processing将处理器分配到的层级。如果您未声明此选项,Atlas Stream Processing 会将处理器分配给流处理工作区的层级。必须是以下之一:
要学习;了解更多信息,请参阅层级。 |
| 对象 | Optional | |
| 布尔 | 可选的 | 打开或关闭自动扩展。设立 |
| 字符串 | Optional | 处理器可以扩展到的最低层级。如果您不指定此字段, Atlas Stream Processing将使用流处理工作区默认层级和启动处理器的层级中较低的一个。 |
| 字符串 | Optional | 处理器可以扩展到的最高层级。如果您不指定此字段, Atlas Stream Processing将使用流处理工作区的最大层级大小。 |
| 布尔 | Optional | 指定此启动请求是否跳过检查点恢复。当设立为 |
| 布尔 | Optional | 指定处理器启动时是否从最近的检查点恢复。默认下,该字段为 |
行为
sp.processor.start() 在当前流处理工作区上启动已命名的流处理器。流处理器必须处于 STOPPED 省。如果您为不是 STOPPED 的流处理器调用 sp.processor.start(),mongosh 将返回错误。
访问控制
运行sp.processor.start() 的用户必须具有atlasAdmin角色。
例子
以下示例启动一个名为solarDemo的流处理器。
sp.solarDemo.start()