MongoDB\ChangeStream::getResumeToken()

Definición

MongoDB\ChangeStream::getResumeToken()

Devuelve el token de reanudación en caché que se utilizará para reanudar el flujo de cambios.

function getResumeToken(): array|object|null

Return Values

Un arreglo u objeto, o null si no hay ningún token de reanudación almacenado en caché. El tipo de retorno dependerá de la opción typeMap que se use en el método watch() para crear el flujo de cambios.

Ejemplos

Este ejemplo captura el token de reanudación para un flujo de cambios después de encontrar un evento invalidate y lo utiliza para construir un segundo flujo de cambios usando la opción 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]);

Ver también

• MongoDB\Client::watch()

• MongoDB\Collection::watch()

• MongoDB\Database::watch()

• Reanudar una Change Stream en la documentación del manual de MongoDB