MongoDB\ChangeStream::getResumeToken()

이 페이지의 내용

정의

Return Values
예시
다음도 참조하세요.

버전 1.5에 새로 추가되었습니다.

정의

MongoDB\ChangeStream::getResumeToken()

변경 스트림을 재개하는 데 사용할 캐시된 재개 토큰을 반환합니다.

function getResumeToken(): array|object|null

Return Values

배열 또는 객체이거나 캐시된 재개 토큰이 없는 경우 null 입니다. 반환 유형은 변경 스트림을 만드는 데 사용된 watch() 메서드의 typeMap 옵션에 따라 달라집니다.

예시

이 예에서는 invalidate 이벤트 발생 후 변경 스트림에 대한 재개 토큰을 캡처하고 이를 사용하여 startAfter 옵션으로 두 번째 변경 스트림을 구성합니다.

<?php
$uri = 'mongodb://rs1.example.com,rs2.example.com/?replicaSet=myReplicaSet';
$collection = (new MongoDB\Client($uri))->test->inventory;
$changeStream = $collection->watch();
for ($changeStream->rewind(); true; $changeStream->next()) {
    if ( ! $changeStream->valid()) {
        continue;
    }
    $event = $changeStream->current();
    if ($event['operationType'] === 'invalidate') {
        $startAfter = $changeStream->getResumeToken();
        break;
    }
    printf("%d: %s\n", $changeStream->key(), $event['operationType']);
}
$changeStream = $collection->watch([], ['startAfter' => $startAfter]);

다음도 참조하세요.

돌아가기

getCursorId()

key()