Ações de privilégio de processamento de fluxo

Resumo de funções integradas

A tabela a seguir mostra as funções integradas que incluem ações de privilégio do Atlas Stream Processing.

Ações do Atlas Stream Processing

createStreamProcessor

Autoriza o método sp.createStreamProcessor(), que define um novo processador de fluxo nomeado com seu pipeline e opções.

Atribua esta ação para permitir que os usuários criem processadores de fluxo nomeados antes de iniciá-los.

Observação

O Atlas Stream Processing valida o formato do tier no momento da criação. O Atlas Stream Processing força o tamanho máximo do tier quando você inicia o processador, não quando o cria.

dropStreamProcessor

Autoriza o método sp.processor.drop(), que exclui permanentemente um processador de fluxo nomeado.

Atribua esta ação para permitir que os usuários excluam processadores de Stream Processing. Um usuário com esta ação pode excluir qualquer processador no workspace de Stream Processing. Nenhum mecanismo restringe esta ação a processadores nomeados específicos.

getStreamProcessor

Autoriza o comando getStreamProcessor, que recupera o estado e a configuração de um processador de fluxo nomeado. Os resultados incluem nome, estado, pipeline, mensagem de erro e hora da última alteração de estado.

Atribua esta ação para permitir que os usuários inspecionem o estado de um processador de fluxo específico.

listStreamConnections

Autoriza o método sp.listConnections(), que lista todas as conexões no registro de conexões do workspace de Stream Processing. Dependendo do tipo de conexão, os resultados podem incluir nome da conexão, tipo, nome do cluster, ID do projeto, região, servidores de bootstrap e campos da conta de armazenamento.

Atribua esta ação para permitir que os usuários visualizem as fontes de dados e os sinks disponíveis para processadores de stream no workspace de Stream Processing.

listStreamProcessors

Autoriza o método sp.listStreamProcessors(), que lista todos os processadores de Stream Processing em um espaço de trabalho de Stream Processing. Os resultados podem incluir nome, ID, última hora de modificação, estado, tier, mensagem de erro, contagem de trabalhadores, pipeline, fila de mensagens não entregues (DLQ) e última hora de alteração de estado. Você pode passar um filtro para restringir os resultados.

Atribua esta ação para permitir que os usuários descubram todos os processadores de Stream Processing em um espaço de trabalho de Stream Processing. Os drivers e as FERRAMENTAS também exigem esta ação para preencher as listas de processadores. O comando retorna todos os processadores no espaço de trabalho de Stream Processing. Nenhum mecanismo restringe a visibilidade a processadores nomeados específicos.

modifyStreamProcessor

Autoriza o método sp.processor.modify(), que modifica um processador de fluxo existente.

Atribua esta ação para permitir que os usuários atualizem a configuração de um processador de fluxo sem exclui-lo e recriá-lo.

processStreamProcessor

Autoriza o comando processStreamProcessor, que executa um pipeline de processamento de fluxo no modo de disparo único sem criar um processador nomeado.

Atribua esta ação para permitir que os usuários executem um pipeline no modo one-shot.

Observação

Para executar o método mongosh sp.process(), atribua também a ação de privilégio sampleStreamProcessor. sp.process() usa o mecanismo de amostra internamente e requer ambos os privilégios.

sampleStreamProcessor

Autoriza o método sp.processor.sample() e os comandos startSampleStreamProcessor e getMoreSampleStreamProcessor subjacentes. Use startSampleStreamProcessor para iniciar uma sessão de amostragem em um processador de fluxo nomeado e em execução. Use getMoreSampleStreamProcessor para recuperar o próximo lote de resultados. O tamanho do lote padrão é 5 quando batchSize é 0 ou omitido.

Atribua esta ação para permitir que os usuários visualizem a saída ao vivo de um processador de fluxo em execução ou paginem resultados amostrados. A sessão de amostragem se anexa à saída ao vivo do processador. O processador produz resultados apenas durante a execução.

startStreamProcessor

Autoriza o método sp.processor.start(), que inicia ou retoma um processador de fluxo nomeado.

Atribua esta ação para permitir que os usuários iniciem ou retomem um processador de fluxo nomeado.

stopStreamProcessor

Autoriza o método sp.processor.stop(), que interrompe um processador de fluxo nomeado em execução.

Atribua esta ação para permitir que os usuários pausem ou interrompam um processador de fluxo em execução.

streamProcessorStats

Autoriza o método sp.processor.stats(), que usa o comando getStreamProcessorStats para recuperar métricas operacionais para um processador de fluxo. O Atlas Stream Processing omite o documento de estatísticas quando não há métricas disponíveis. Passe verbose: true para obter mais detalhes. O modo detalhado não requer privilégio separado.

Atribua esta ação para permitir que os usuários monitorem a taxa de transferência, as taxas de erro ou as métricas operacionais de um processador de fluxo.