How to stop a mongodb changestream temporarily and resume it again? public Flux<Example> watch() { final ChangeStreamOptions changeStreamOptions = ChangeStreamOptions.builder().returnFullDocumentOnUpdate().build(); return reactiveMongoTemplate.changeStream("collection", changeStreamOptions, Example.class) .filter(e -> e.getOperationType() != null) .mapNotNull(ChangeStreamEvent::getBody); } I'm trying to create a rest endpoint that should…
What is the difference b/w the behavior of resumeAt that accepts a timestamp to resume the notifications from vs resumeToken that accepts the resume token? return ChangeStreamOptions.builder() .filter(Aggregation.newAggregation(Example.class, matchOperationType)) .resumeAt(Instant.ofEpochSecond(1675303335)) // this is simply a unix timestamp .resumeToken(tokenDoc) // resume…
I am utilizing change streams from documentDB to read timely sequenced events using lambda, event bridge to trigger event every 10min to invoke lambda and to archive the data to S3. Is there a way to scale the read from…
I've been trying to implement a change stream that monitors a Mongo collection for new documents. While simple to setup for catching one change, I don't understand how to keep the process running indefinitely. db = pymongo_util.get_collection("DataDB","XYZ_Collection") stream = db.watch(full_document="updateLookup"):…
I'm using mongo watch() to subscribe to change stream events. I've noticed that the change stream events automatically stopped without throwing any specific error and become idle. Then have to restart the server to listen to the change stream again.…