Mongo.watch()

정의

Mongo.watch( pipeline, options )

복제본 세트 및 샤딩된 클러스터 전용

복제본 세트 또는 샤딩된 클러스터 에 대한 변경 스트림 커서 를 열어 admin, local 및 config 데이터베이스를 제외한 해당 데이터베이스 전체의system 이 아닌 모든 컬렉션에 대해 보고합니다. .

Parameter	유형	설명
pipeline	배열	선택 사항입니다. 다음 집계 단계 중 하나 이상으로 구성된 집계 파이프라인: $addFields $match $project $replaceRoot $replaceWith $redact $set $unset 변경 이벤트 출력을 필터링/수정할 파이프라인을 지정합니다. MongoDB 4.2부터 변경 스트림 집계 파이프라인이 이벤트의 _id 필드를 수정하면 변경 스트림이 예외를 스로우합니다.
options	문서	선택 사항. Mongo.watch() 의 동작을 수정하는 추가 옵션입니다.

options 문서에는 다음과 같은 필드 및 값이 포함될 수 있습니다.

필드	유형	설명
resumeAfter	문서	선택 사항입니다. 재개 토큰에 지정된 작업 이후에 알림 재개를 시도하도록 Mongo.watch()에 지시합니다. 각 변경 스트림 이벤트 문서에는 _id 필드로 이력서 토큰이 포함되어 있습니다. 이후에 재개하려는 작업을 나타내는 변경 이벤트 문서의 전체 _id 필드를 전달하십시오. resumeAfter 의 경우 startAfter 및 startAtOperationTime과 상호 배타적입니다.
startAfter	문서	선택 사항입니다. 다시 시작 토큰에 지정된 작업 후 Mongo.watch()에 새 변경 스트림 시작을 시도하도록 지시합니다. 무효화 이벤트 후에 알림을 다시 시작할 수 있습니다. 각 변경 스트림 이벤트 문서에는 _id 필드로 이력서 토큰이 포함되어 있습니다. 이후에 재개하려는 작업을 나타내는 변경 이벤트 문서의 전체 _id 필드를 전달하십시오. startAfter 의 경우 resumeAfter 및 startAtOperationTime과 상호 배타적입니다.
fullDocument	문자열	선택 사항입니다. 기본적으로 Mongo.watch()는 업데이트된 전체 문서 대신 업데이트 작업으로 수정된 필드의 델타를 반환합니다. fullDocument를 "updateLookup"로 설정하여 Mongo.watch()가 업데이트된 문서의 가장 최근에 대다수 커밋된 버전을 찾도록 지시합니다. Mongo.watch()는 updateDescription 델타에 더해 문서 조회가 있는 fullDocument 필드를 반환합니다.
batchSize	int	선택 사항입니다. MongoDB cluster의 각 응답 배치에서 반환할 최대 변경 이벤트 수를 지정합니다. cursor.batchSize()와 동일한 기능을 갖습니다.
maxAwaitTimeMS	int	선택 사항입니다. 서버가 빈 배치를 반환하기 전에 변경 스트림 커서에 보고할 새 데이터 변경 내용을 기다리는 최대 시간(밀리초)입니다. 기본값은 1000밀리초입니다.
collation	문서	선택 사항입니다. 데이터 정렬 문서를 전달하여 변경 스트림 커서에 대한 데이터 정렬을 지정합니다. 생략하면 기본값은 simple 바이너리 비교입니다.
startAtOperationTime	타임스탬프	선택 사항입니다. 변경 스트림의 시작 지점입니다. 지정된 시작점이 과거인 경우 oplog의 시간 범위 내에 있어야 합니다. oplog의 시간 범위를 확인하려면 rs.printReplicationInfo()를 참조하십시오. startAtOperationTime 의 경우 resumeAfter 및 startAfter과 상호 배타적입니다.

반환합니다:	변경 이벤트 문서 위에 커서가 있습니다. 변경 이벤트 문서의 예는 변경 이벤트에서 확인하세요.

팁

다음도 참조하세요.

db.collection.watch() 개인정보 정책에 db.watch()

가용성

행동

• Mongo.watch() 대부분의 데이터 보유 멤버에게 지속된 데이터 변경 사항에 대해서만 알립니다.

• 변경 스트림 커서는 다음 중 하나가 발생할 때까지 열려 있습니다.

  • 커서가 명시적으로 닫힙니다.

  • 무효화 이벤트가 발생합니다. 예를 들어 컬렉션 제거 또는 이름 바꾸기가 있습니다.

  • MongoDB 배포에 대한 연결이 닫히거나 시간 초과됩니다. 자세한 내용은 Cursor Behaviors를 참조하십시오.

  • 배포가 샤딩된 클러스터인 경우 샤드를 제거하면 열려 있는 변경 스트림 커서가 닫힐 수 있습니다. 닫힌 변경 스트림 커서는 완전히 재개되지 않을 수 있습니다.

snippet install resumetoken
decodeResumeToken('<RESUME TOKEN>')

npx mongodb-resumetoken-decoder <RESUME TOKEN>

액세스 제어

액세스 제어를 사용하여 실행하는 경우 사용자는 모든 데이터베이스의 모든 비시스템 컬렉션에 대해 find 및 changeStream 권한 작업을 수행해야 합니다. 즉, 사용자의 역할이 다음 권한을 부여해야 합니다.

{ resource: { db: "", collection: "" }, actions: [ "find", "changeStream" ] }

기본 제공 read 역할은 적절한 권한을 제공합니다.

커서 반복

MongoDB는 커서를 반복하는 다양한 방법을 제공합니다.

cursor.hasNext() 메서드는 다음 이벤트를 차단하고 기다립니다. watchCursor 커서를 모니터링하고 이벤트를 반복하려면 hasNext()를 다음과 같이 사용합니다.

while (!watchCursor.isClosed()) {
   if (watchCursor.hasNext()) {
     firstChange = watchCursor.next();
     break;
   }
}

cursor.tryNext() 메서드는 비차단입니다. watchCursor 커서를 모니터링하고 이벤트를 반복하려면 tryNext()를 다음과 같이 사용합니다.

while (!watchCursor.isClosed()) {
  let next = watchCursor.tryNext()
  while (next !== null) {
    printjson(next);
    next = watchCursor.tryNext()
  }
}

예시

mongosh에서 다음 작업은 복제본 세트에서 변경 스트림 커서를 엽니다. 반환된 커서는 admin, local 및 config 데이터베이스를 제외한 모든 데이터베이스의 모든 비system 컬렉션에 대한 데이터 변경 사항을 보고합니다.

watchCursor = db.getMongo().watch()

커서를 반복하여 새 이벤트를 확인합니다. 2} 메서드를 cursor.isClosed() 메서드와 함께 cursor.tryNext()를 사용하여 변경 스트림 커서가 닫혀 있고 최신 배치에 객체가 남아 있지 않은 경우에만 루프가 종료되도록 합니다:

while (!watchCursor.isClosed()) {
  let next = watchCursor.tryNext()
  while (next !== null) {
    printjson(next);
    next = watchCursor.tryNext()
  }
}

변경 스트림 출력에 대한 전체 문서는 변경 이벤트를 참조하십시오.