권한 작업은 데이터베이스 사용자 또는 사용자 지정 역할 이 Stream Processing 작업 공간 내의 스트림 프로세서에서 수행할 수 있는 작업을 정의합니다. 사용자에게 또는 사용자 지정 역할에 필요한 권한 작업만 할당합니다.
모든 권한 조치는 Stream Processing 작업 공간 전체에 적용됩니다. Stream Processing 워크스페이스 내의 개별 명명된 프로세서에 스코프를 지정할 수 없습니다. 모든 조치는 Atlas Stream Processing 인스턴스에서만 유효합니다.
atlasAdmin 또는 readWriteAnyDatabase 역할을 가진 사용자는 모든 Stream Processing 조치를 수행할 수 있습니다. readAnyDatabase 역할을 가진 사용자는 읽기 전용 하위 집합을 수행할 수 있습니다. 자세한 내용은 내장 역할 요약.을 참조하십시오.
사용자에게 조치에 필요한 권한이 없으면 명령이 MongoServerError[Unauthorized]: not authorized: missing privilege for action <privilege-action> on resource <resource>을(를) 반환합니다.
특정 Atlas Stream Processing 권한 조치를 포함하여 사용자 지정 역할을 만들려면 사용자 지정 역할 추가를 참조하세요.
내장 역할 요약
다음 표에는 Atlas Stream Processing 권한 조치를 포함하는 내장 역할이 표시됩니다.
내장 역할 | 포함된 권한 조치 |
|---|---|
모든 Atlas Stream Processing 권한 조치 | |
| |
모든 Atlas Stream Processing 권한 조치 |
Atlas Stream Processing 조치
createStreamProcessor파이프라인과 옵션이 포함된 새로운 이름 스트림 프로세서를 정의하는
sp.createStreamProcessor()메서드에 권한을 부여합니다.사용자가 명명된 스트림 프로세서를 시작하기 전에 만들 수 있도록 이 조치를 할당합니다.
참고
Atlas Stream Processing은 생성 시점에서 계층 형식의 유효성을 검사합니다. Atlas Stream Processing은 프로세서를 생성할 때가 아니라 시작할 때 최대 계층 크기를 시행합니다.
dropStreamProcessor이름이 지정된 스트림 프로세서를 영구적으로 삭제하는
sp.processor.drop()메서드에 권한을 부여합니다.사용자가 Stream Processing 프로세서를 삭제할 수 있도록 이 조치를 할당합니다. 이 조치를 사용하는 사용자는 Stream Processing 작업 공간의 모든 프로세서를 삭제할 수 있습니다. 이 조치를 특정 이름의 프로세서로 제한하는 메카니즘은 없습니다.
getStreamProcessor명명된 스트림 프로세서의 상태와 구성을 조회하는
getStreamProcessor명령을 인증합니다. 결과에는 이름, 상태, 파이프라인, 오류 메시지 및 마지막 상태 변경 시간이 포함됩니다.이 조치를 할당하여 사용자가 특정 스트림 프로세서의 상태를 검사할 수 있도록 합니다.
listStreamConnectionsStream Processing 워크스페이스 연결 등록소에 있는 모든 연결을 나열하는
sp.listConnections()메서드에 권한을 부여합니다. 연결 유형에 따라 결과에는 연결 이름, 유형, 클러스터 이름, 프로젝트 ID, 리전, 부트스트랩 서버 및 저장 계정 필드가 포함될 수 있습니다.이 조치를 할당하여 사용자가 Stream Processing 워크스페이스에서 Stream Processor에 사용할 수 있는 데이터 소스 및 싱크를 볼 수 있도록 합니다.
listStreamProcessorsStream Processing 작업 공간에 있는 모든 스트림 프로세서를 나열하는
sp.listStreamProcessors()메서드를 승인합니다. 결과에는 이름, ID, 마지막 수정 시간, 상태, 계층, 오류 메시지, 워커 수, 파이프라인, 데드 레터 큐 및 마지막 상태 변경 시간이 포함될 수 있습니다. 필터를 전달하여 결과를 제한할 수 있습니다.이 조치를 할당하여 사용자가 Stream Processing 작업 영역에서 모든 Stream Processor를 찾을 수 있도록 합니다. 드라이버와 도구에도 프로세서 목록을 채우려면 이 조치가 필요합니다. 이 명령은 Stream Processing 작업 영역에서 모든 프로세서를 반환합니다. 특정 이름의 프로세서에 대한 가시성을 제한하는 메카니즘은 없습니다.
modifyStreamProcessor기존 스트림 프로세서를 수정하는
sp.processor.modify()메서드를 승인합니다.이 조치를 할당하여 사용자가 스트림 프로세서를 삭제하고 다시 만들지 않고도 구성을 업데이트할 수 있도록 합니다.
processStreamProcessor이름이 지정된 프로세서를 생성하지 않고 원샷 모드로 스트림 처리 파이프라인을 실행하는
processStreamProcessor명령에 권한을 부여합니다.이 조치를 할당하여 사용자가 파이프라인을 원샷 모드로 실행할 수 있도록 합니다.
참고
sp.process()mongosh 메서드를 실행하려면sampleStreamProcessor권한 조치도 할당해야 합니다.sp.process()는 내부적으로 샘플 메커니즘을 사용하며 두 권한이 모두 필요합니다.
sampleStreamProcessorsp.processor.sample()메서드와 기본startSampleStreamProcessor및getMoreSampleStreamProcessor명령을 승인합니다.startSampleStreamProcessor을 사용하여 이름이 지정된 실행 중인 스트림 프로세서에서 샘플링 세션을 시작합니다.getMoreSampleStreamProcessor을 사용하여 다음 배치 결과를 조회합니다.batchSize가 0 이거나 생략된 경우 기본 배치 크기는 5 입니다.이 조치를 할당하여 사용자가 실행 중인 스트림 프로세서의 실시간 출력을 미리 보거나 샘플 결과를 페이지별로 볼 수 있도록 합니다. 샘플 세션은 프로세서의 실시간 출력에 연결됩니다. 프로세서는 실행 중에만 결과를 생성합니다.
startStreamProcessor명명된 Stream Processing를 시작하거나 이어서 시작하는
sp.processor.start()메서드에 권한을 부여합니다.이 조치를 할당하여 사용자가 명명된 스트림 프로세서를 시작하거나 다시 시작할 수 있도록 합니다.
stopStreamProcessor실행 중인 이름 스트림 프로세서를 중지하는
sp.processor.stop()메서드에 대한 권한을 부여합니다.사용자가 실행 중인 스트림 프로세서를 일시 중지하거나 중단할 수 있도록 이 조치를 할당합니다.
streamProcessorStatsgetStreamProcessorStats명령을 사용하여 스트림 처리기의 운영 지표를 조회하는sp.processor.stats()메서드에 권한을 부여합니다. Atlas Stream Processing은 지표가 없는 경우 통계 문서를 생략합니다. 자세한 내용은verbose: true을 참조하세요. 상세 모드에는 별도의 권한이 필요하지 않습니다.이 작업을 할당하여 사용자가 스트림 프로세서의 처리량, 오류 률 또는 운영 지표를 모니터링할 수 있도록 합니다.