MongoDB\ChangeStream::getResumeToken()
1.5 版本中的新增功能。
定义
Return Values
数组或对象,如果没有缓存的恢复令牌,则为null
。 返回类型将取决于用于创建变更流的watch()
方法的typeMap
选项。
示例
此示例在遇到invalidate
事件后捕获变更流的恢复令牌,并使用它来构造第二个变更流(通过startAfter
选项)。
$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]);