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

Una matriz u objeto, o null si no hay un token de resumen en caché. El tipo de retorno dependerá de la opción typeMap del método watch() utilizado para crear el flujo de cambios.

Ejemplos

Este ejemplo captura el token de reanudación de un flujo de cambio después de encontrar un evento invalidate y lo utiliza para construir un segundo flujo de cambio utilizando 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()

• Documentación sobre cómo reanudar un flujo de cambios en el manual de MongoDB