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, que define um novo processador de stream nomeado com seu pipeline e sp.createStreamProcessor() 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, que exclui permanentemente um processador de stream sp.processor.drop() 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 sp.listConnections() método, que lista todas as conexões no registro de conexão do espaço de trabalho de processamento de fluxo. 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 inicialização e campos de 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, que lista todos os processadores de stream em um workspace de processamento de stream. Os resultados podem incluir nome, ID, tempo da última modificação, estado, nível, mensagem de erro, contagem de trabalhadores, pipeline, fila de mensagens não entregues (DLQ)(DLQ) e tempo da última alteração de estado. Você pode passar um filtro para restringir sp.listStreamProcessors() 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, que modifica um processador de fluxo sp.processor.modify() 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, atribua também sp.process() a sampleStreamProcessor ação de privilégio. sp.process() usa o mecanismo de amostra internamente e exige ambos os privilégios.

sampleStreamProcessor

Autoriza o método e sp.processor.sample() os startSampleStreamProcessor getMoreSampleStreamProcessor comandos e 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, que inicia ou retoma um processador de stream sp.processor.start() nomeado.

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

stopStreamProcessor

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

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, que utiliza sp.processor.stats() o getStreamProcessorStats comando para recuperar métricas operacionais para um processador de fluxo. O Atlas Stream Processing omite o documento de estatísticas quando nenhuma métrica está disponível. Passe verbose: true para obter mais detalhes. O modo Verbose não requer privilégio separados .

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.