Docs Home

/ /

Atlas Stream Processing

Docs Home

/ /

Mongo쉬 방법

Atlas Stream Processing

Atlas Stream Processing

sp.processor.stats() (mongosh 메서드)

정의

sp.processor.stats()

버전 7.0의 새로운 기능: 현재 스트림 처리 작업 공간 에서 현재 실행스트림 프로세서의 통계가 포함된 문서 반환합니다.

호환성

이 메서드는 Atlas Stream Processing Workspaces에서 지원됩니다.

구문

sp.processor.stats() 메서드의 구문은 다음과 같습니다.

sp.processor.stats( { options: { scale: <int>, verbose: <boolean> } } )

명령 필드

sp.processor.stats() 는 다음 필드를 사용합니다.

필드	유형	필요성	설명
`options`	객체	옵션	통계 보고서에 대한 다양한 선택적 설정을 정의하는 객체입니다.
`options.scale`	integer	옵션	출력에 설명된 항목의 크기에 사용하는 단위입니다. `1024` 로 설정하면 출력 문서에 크기가 키비바이트 단위로 표시됩니다. 기본값은 바이트입니다.
`options.verbose`	부울	옵션	출력 문서의 상세 수준을 지정하는 플래그입니다. `true` 로 설정하면 출력 문서에는 파이프라인의 각 개별 연산자에 대한 통계를 보고하는 하위 문서가 포함됩니다. 기본값은 `false` 입니다.

행동

sp.processor.stats() 지정된 스트림 프로세서에 대한 통계가 포함된 문서를 STDOUT 로 반환합니다. 이러한 통계에는 다음이 포함되지만 이에 국한되지는 않습니다.

수집 및 처리된 메시지 수
모든 입력 및 출력의 총 크기
프로세서 상태를 저장하는 데 사용되는 메모리의 양

현재 실행 중인 스트림 프로세서에서만 sp.processor.stats() 를 호출할 수 있습니다. 중지된 스트림 프로세서에서 이 명령을 호출하려고 하면 mongosh 에서 오류를 반환합니다.

액세스 제어

The user running sp.processor.stats() must have the atlasAdmin role.

예시

다음 예제에서는 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' ]
      }
    }
  ]
}

자세히 알아보기

스트림 프로세서 관리

돌아가기

sp.processor.start

sp.processor.stop()