定义
版本7.0 中的新增功能:在当前流处理工作区上启动已命名的 流处理器。
兼容性
语法
sp.processor.start() 方法使用的语法如下:
sp.processor.start( { <options> } )
命令字段
sp.processor.start() 采用这些字段:
字段 | 类型 | 必要性 | 说明 |
|---|---|---|---|
| token | 可选的 | |
| timestamp | 可选的 | |
| 字符串 | Optional | Atlas Stream Processing将处理器分配到的层级。如果您未声明此选项, Atlas Stream Processing会将处理器分配给流处理工作区的层级。必须是以下之一:
|
行为
sp.processor.start() 在当前流处理工作区上启动已命名的流处理器。流处理器必须处于 STOPPED 状态。如果您为不是 STOPPED 的流处理器调用 sp.processor.start(),mongosh 将返回错误。
访问控制
运行sp.processor.start()的用户必须具有atlasAdmin角色。
例子
以下示例启动一个名为solarDemo的流处理器。
sp.solarDemo.start()