Acciones de privilegio de Stream Processing

Resumen de roles integrados

En la siguiente tabla se muestran los roles integrados que incluyen acciones de privilegio de Stream Processing de Atlas.

Acciones de Atlas Stream Processing

createStreamProcessor

Autoriza el método sp.createStreamProcessor(), que define un nuevo procesador de transmisión con nombre con su pipeline y opciones.

Asigne esta acción para permitir a los usuarios crear procesadores de transmisión con nombre antes de iniciarlos.

Nota

Atlas Stream Processing valida el formato de nivel en el momento de la creación. Atlas Stream Processing aplica el tamaño máximo de nivel cuando inicia el procesador, no cuando lo crea.

dropStreamProcessor

Autoriza el método sp.processor.drop(), que elimina permanentemente un procesador de Stream con nombre.

Asigne esta acción para permitir a los usuarios borrar Stream Processing. Un usuario con esta acción puede borrar cualquier procesador en el espacio de trabajo de Stream Processing. Ningún mecanismo restringe esta acción a procesadores con nombre específicos.

getStreamProcessor

Autoriza el comando getStreamProcessor, que recupera el estado y la configuración de un procesador de transmisión con nombre. Los resultados incluyen el nombre, el estado, el pipeline, el mensaje de error y la hora del último cambio de estado.

Asigne esta acción para permitir a los usuarios inspeccionar el estado de un procesador de transmisión específico.

listStreamConnections

Autoriza el método sp.listConnections(), que enumera todas las conexiones en el registro de conexiones del espacio de trabajo de Stream Processing. Según el tipo de conexión, los resultados pueden incluir el nombre de la conexión, el tipo, el nombre del clúster, el ID del proyecto, la región, los servidores de arranque y los campos de la cuenta de almacenamiento.

Asigna esta acción para permitir a los usuarios ver las fuentes de datos y los receptores disponibles para los procesadores de Stream Processing en el espacio de trabajo de Stream Processing.

listStreamProcessors

Autoriza el método sp.listStreamProcessors(), que enumera todos los procesadores de streaming en un espacio de trabajo de Stream Processing. Los resultados pueden incluir nombre, ID, última hora de modificación, estado, nivel, mensaje de error, recuento de trabajadores, pipeline, fila de letra muerta y última hora de cambio de estado. Puede pasar un filtro para reducir los resultados.

Asigne esta acción para permitir a los usuarios descubrir todos los procesadores de Stream Processing en un espacio de trabajo de Stream Processing. Los drivers y las herramientas también requieren esta acción para rellenar las listas de procesadores. El comando devuelve todos los procesadores en el espacio de trabajo de Stream Processing. Ningún mecanismo restringe la visibilidad a procesadores específicos con nombre.

modifyStreamProcessor

Autoriza el método sp.processor.modify(), que modifica un procesador de transmisión existente.

Asigne esta acción para permitir a los usuarios actualizar la configuración de un procesador de transmisión sin borrarlo y volver a crearlo.

processStreamProcessor

Autoriza el comando processStreamProcessor, que ejecuta un pipeline de procesamiento de transmisión en modo de una sola vez sin crear un procesador con nombre.

Asigne esta acción para permitir a los usuarios ejecutar un pipeline en modo de una sola moda.

Nota

Para ejecutar el método mongosh sp.process(), asigne también la acción de privilegio sampleStreamProcessor. sp.process() utiliza el mecanismo de muestra internamente y requiere ambos privilegios.

sampleStreamProcessor

Autoriza el método sp.processor.sample() y los comandos subyacentes startSampleStreamProcessor y getMoreSampleStreamProcessor. Utilice startSampleStreamProcessor para iniciar una sesión de muestreo en un procesador de transmisión con nombre en ejecución. Utilice getMoreSampleStreamProcessor para recuperar el siguiente lote de resultados. El tamaño de lote por defecto es 5 cuando batchSize es 0 o se omite.

Asigne esta acción para permitir a los usuarios previsualizar la salida en vivo de un procesador de transmisión en ejecución o paginar a través de los resultados de la muestra. La sesión de muestreo se adjunta a la salida en vivo del procesador. El procesador produce resultados solo mientras se ejecuta.

startStreamProcessor

Autoriza el método sp.processor.start(), que inicia o reanuda un procesador de transmisión con nombre.

Asigne esta acción para permitir a los usuarios iniciar o reanudar un Stream Processing con nombre.

stopStreamProcessor

Autoriza el método sp.processor.stop(), que detiene un procesador de transmisión con nombre en ejecución.

Asigne esta acción para permitir que los usuarios pausen o detengan un procesador de flujos en ejecución.

streamProcessorStats

Autoriza el método sp.processor.stats(), que utiliza el comando getStreamProcessorStats para recuperar métricas operativas para un procesador de Stream Processing. Atlas Stream Processing omite el documento de estadísticas cuando no hay métricas disponibles. Pase verbose: true para más detalles. El modo detallado no requiere un privilegio independiente.

Asigne esta acción para permitir a los usuarios supervisar el rendimiento, las tasas de error o las métricas operativas de un procesador de transmisión.