Atlas Stream Processing 모니터링 및 알림
이 페이지의 내용
Atlas Stream Processing은 모니터링 및 경고 기능을 제공하여 사용자가 성능 및 상태 인사이트를 활용하여 워크플로를 개선할 수 있도록 합니다.
스트림 프로세서 모니터링 방법
Atlas Stream Processing은 스트림 프로세서에 대한 주문형 보고를 위한 다음과 같은 방법을 제공합니다.
sp.processor.sample() 메서드를 사용하면 현재 실행 중인 선택한 스트림 프로세서에서 출력한 문서의 작은 샘플을 볼 수 있습니다. 사용자는 샘플링된 결과를 예상 결과와 비교하여 집계 파이프라인 설계의 오류를 진단할 수 있습니다.
sp.processor.stats() 메서드는 선택한 스트림 프로세서에 대한 다양한 런타임 통계를 반환합니다. 여기에는 다음이 포함되지만 이에 국한되지는 않습니다.
수집된 메시지 수
성공적으로 처리된 메시지 수
Dead Letter Queue에 전송된 메시지 수
파이프라인 상태의 인메모리 크기
파이프라인 정의
스트림 프로세서 경고
Atlas Stream Processing은 프로세서의 상태가 변경되거나 프로세서가 다양한 수집 또는 출력 임계값을 충족할 때 경고를 발생시킵니다. 사용 가능한 Atlas Stream Processing 알림 목록을 보려면 Atlas Stream Processing 경고를 참조하세요. 경고 구성에 대한 자세한 내용은 경고 설정 구성을 참조하세요.
다음과 같은 방법으로 Atlas Stream Processing 경고를 대상으로 지정할 수 있습니다.
프로젝트 내의 모든 스트림 프로세서
구성된 조건자와 일치하는 스트림 처리 인스턴스 내의 모든 스트림 프로세서
이름이 구성된 술어와 일치하는 모든 스트림 프로세서
모든 스트림 프로세서가 아닌 다른 대상의 경우, 동일한 경고에 대해 여러 대상을 구성할 수 있습니다.