MongoDB\ChangeStream::getResumeToken()

Novidades na versão 1.5.

Definição

MongoDB\ChangeStream::getResumeToken()

Retorna o token de retomada em cache que será usado para retomar o change stream.

function getResumeToken(): array|object|null

Return Values

Uma array ou objeto, ou null se não houver nenhum token de resumo em cache. O tipo de retorno depende da opção typeMap para o método watch() utilizado para criar o change stream.

Exemplos

Este exemplo captura o token de retomada de um change stream após encontrar um evento invalidate e o usa para construir um segundo change stream usando a opção 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]);

Veja também

MongoDB\Client::watch()
MongoDB\Collection::watch()
MongoDB\Database::watch()
Retomar a documentação de um change stream no Manual do MongoDB

Voltar

getCursorId()

chave()