Lalitha Chevuru

Lalitha Chevuru

  • NA
  • 84
  • 4.6k

BatchSize option is not working in ChangeStream WatchAsync

May 9 2023 10:29 AM

Hi Team,

I am using ChangeStream for catch my backend deletions and send mails which is working fine.
In case of bulk deletions I want to send only few e-mails hence I am using BatchSize, some how it is not working.
As per my understanding, depending on BatchSize setting those many changes should capture.
I set BatchSize is 2, when I delete 5 records from collection it should only send 2 mails as I set BatchSize is 2, however it is sending all 5 mails.
Please help me to fix this issue. Below is my code:

public async Task RealtionalCollectionCollectionChange(CancellationToken cancellationToken)

{var options = new ChangeStreamOptions

{ FullDocument = ChangeStreamFullDocumentOption.UpdateLookup, BatchSize = 2 };

var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>().Match("{operationType: { $in: [ 'replace', 'insert', 'update', 'delete' ] } }");

using (var cursor = await collection.WatchAsync(pipeline, options, cancellationToken))

{

while (await cursor.MoveNextAsync(cancellationToken))

{

if (cancellationToken.IsCancellationRequested) { break; }

foreach (var change in cursor.Current)

{

//Sending mail code 

} break; } } } cursor.Dispose(); } }

Thanks,

Lalitha.C


Answers (2)