Definição
sp.processor.start()Inicia um processador de stream nomeado no workspace de processamento de streamatual.
Você só pode invocar este comando enquanto estiver conectado a um espaço de trabalho de stream processing.
Este comando requer
mongoshversão ≥ 2.0.
Compatibilidade
Esse método é suportado em Atlas Stream Processing Workspaces.
Sintaxe
O método tem a seguinte sp.processor.start() sintaxe:
sp.processor.start( { <options> } )
Campos de comando
sp.processor.start() usa estes campos:
Campo | Tipo | necessidade | Descrição |
|---|---|---|---|
| token | Condicional | Consulte o fluxo de alterações da coleção MongoDB |
| timestamp | Condicional | Consulte o fluxo de alterações da coleção MongoDB |
| string | Opcional | O nível para o qual o Atlas Stream Processing atribui o processador. Se você não declarar esta opção, o Atlas Stream Processing atribuirá o processador ao nível do espaço de trabalho de Stream Processing. Deve ser um dos seguintes:
Para saber mais, consulte Níveis. |
| objeto | Opcional | Objeto que habilita e configura o autoscaling vertical do processador. Para saber mais, consulte Habilitar e configurar o autoscaling. |
| booleano | Condicional | Ativa ou desativa o autoscaling. Necessário quando você define |
| string | Opcional | O nível mais baixo para o qual o processador pode reduzir. Se você não especificar este campo, o Atlas Stream Processing utilizará o mais baixo do nível padrão do espaço de trabalho de processamento de fluxo e o nível em que você inicia o processador. |
| string | Opcional | O nível mais alto para o qual o processador pode escalar. Se você não especificar este campo, o Atlas Stream Processing usará o tamanho máximo da camada do Stream Processing Workspace. |
| booleano | Opcional | Especifica se esta solicitação de início ignora a recuperação do checkpoint . Quando definido para |
| booleano | Opcional | Especifica se o processador retoma a partir do seu checkpoint mais recente quando é iniciado. Por padrão, este campo é |
Comportamento
sp.processor.start() inicia um processador nomeado no espaço de trabalho de stream processing atual. O processador de stream deve estar em um estado STOPPED. Se você invocar sp.processor.start() para um processador de fluxo que não seja STOPPED, mongosh retornará um erro.
Controle de acesso
O usuário que executa o sp.processor.start() deve ter a função atlasAdmin.
Exemplo
O exemplo a seguir inicia um processador de fluxo denominado solarDemo.
sp.solarDemo.start()