sp.processor.stats()
정의
New in version 7.0: 현재스트림 처리 인스턴스 에서 현재 실행 스트림 프로세서 의 통계가 포함된 문서 를 반환합니다.
구문
sp.processor.stats() 메서드의 구문은 다음과 같습니다.
sp.processor.stats()
명령 필드
sp.processor.stats() 는 다음 필드를 사용합니다.
필드 | 유형 | 필요성 | 설명 |
|---|---|---|---|
options | 객체 | 옵션 | 통계 보고서에 대한 다양한 선택적 설정을 정의하는 객체입니다. |
options.scale | integer | 옵션 | 출력에 설명된 항목의 크기에 사용하는 단위입니다. 1024 로 설정하면 출력 문서에 크기가 키비바이트 단위로 표시됩니다. 기본값은 바이트입니다. |
verbose | 부울 | 옵션 | 출력 문서의 상세도 수준을 지정하는 플래그입니다. true 로 설정하면 출력 문서에 파이프라인의 각 개별 연산자에 대한 통계를 보고하는 하위 문서가 포함됩니다. 기본값은 false입니다. |
행동
sp.processor.stats() 지정된 스트림 프로세서에 대한 통계가 포함된 문서를 STDOUT 로 반환합니다. 이러한 통계에는 다음이 포함되지만 이에 국한되지는 않습니다.
수집 및 처리된 메시지 수
모든 입력 및 출력의 총 크기
프로세서 상태를 저장하는 데 사용되는 메모리의 양
현재 실행 중인 스트림 프로세서에서만 sp.processor.stats() 를 호출할 수 있습니다. 중지된 스트림 프로세서에서 이 명령을 호출하려고 하면 mongosh 에서 오류를 반환합니다.
액세스 제어
sp.processor.stats() 을(를) 실행하는 사용자에게는 atlasAdmin 역할이 있어야 합니다.
예시
다음 예제에서는 solarDemo 이라는 스트림 프로세서의 통계를 가져오기 위해 sp.solarDemo.stats() 을(를) 호출할 때 예상되는 응답을 보여 줍니다.
sp.solarDemo.stats()
{ ok: 1, ns: '6500aa277fdbdb6e443a992e.63c1928d768e39423386aa16.solarDemo', stats: { name: 'solarDemo', processorId: '65f9fea5c5154385174af71e', status: 'running', scaleFactor: Long('1'), inputMessageCount: Long('926'), inputMessageSize: 410310, outputMessageCount: Long('383'), outputMessageSize: 425513, dlqMessageCount: Long('0'), dlqMessageSize: Long('0'), stateSize: Long('4504'), watermark: ISODate('2024-03-19T22:16:49.523Z'), ok: 1 }, pipeline: [ { '$source': { connectionName: 'sample_stream_solar', timeField: { '$dateFromString': { dateString: '$timestamp' } } } }, { '$match': { '$expr': { '$ne': [ '$device_id', 'device_8' ] } } }, { '$tumblingWindow': { interval: { size: 10, unit: 'second' }, pipeline: [ { '$group': { _id: [Object], max_temp: [Object], max_watts: [Object], min_watts: [Object], avg_watts: [Object], median_watts: [Object] } } ] } }, { '$merge': { into: { connectionName: 'mongodb1', db: 'solar_db', coll: 'solar_coll' }, on: [ '_id' ] } } ] }