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