Estoy buscando notificaciones de la operación de 'actualización' de un solo documento dentro de una colección, supuestamente cuando ese documento en particular se actualiza, MongoDB notificaría a un cliente .net registrado en 'reloj', pero la realidad es que MongoDB devuelve todos los documentos con operaciones de 'actualización' en la colección, sin importar cómo se establezca la condición de "coincidencia" del filtro.
¿Alguien con experiencia en Change Stream puede ayudar? ¿Es la naturaleza/diseño del flujo de cambios de MongoDB?
A continuación se muestran las piezas de código de prueba del cliente .net C#,
La clase:
public class UserInfo { [BsonId, BsonRepresentation(BsonType.ObjectId)] public string Id { get; set; } [BsonElement("UserName", Order = 1), BsonRepresentation(BsonType.String)] public string UserName { get; set; } [BsonElement("Password", Order = 2), BsonRepresentation(BsonType.String)] public string Password { get; set; } [BsonElement("LastName", Order = 3), BsonRepresentation(BsonType.String)] public string LastName { get; set; } [BsonElement("FirstName", Order = 4), BsonRepresentation(BsonType.String)] public string FirstName { get; set; } [BsonElement("Email", Order = 5), BsonRepresentation(BsonType.String)] public string Email { get; set; } }Tubería de condiciones de filtro:
collection = myDB.GetCollection<UserInfo>("Users"); var options = new ChangeStreamOptions { FullDocument = ChangeStreamFullDocumentOption.UpdateLookup, }; var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<UserInfo>>(); pipeline.Match(g => g.OperationType == ChangeStreamOperationType.Update) .Match(o => o.FullDocument.UserName.Contains("Alice")) .Match(t => t.UpdateDescription.UpdatedFields.ToString().Contains(nameof(UserInfo.Password))); Task watchTask = WatchCollection();Cambiar la rutina del proceso de eventos:
private static async Task WatchCollection() { var cursor = await collection.WatchAsync(pipeline, options); Debug.WriteLine("ChangeStream started."); await cursor.ForEachAsync(change => { Debug.WriteLine("Matched UserName: " + change.FullDocument.UserName); }); }De la rutina anterior, los eventos de cambio no funcionan de acuerdo con las condiciones del filtro, cada vez que se activa esta rutina, 'change.FullDocument.UserName' en realidad imprime todos los documentos de la colección que obtienen la operación de 'actualización', lo cual es bastante extraño. .
Pude hacerlo funcionar con lo siguiente:
var options = new ChangeStreamOptions { FullDocument = ChangeStreamFullDocumentOption.UpdateLookup, BatchSize = 1 }; var filter = Builders<ChangeStreamDocument<UserInfo>> .Filter.Where(x => x.OperationType == ChangeStreamOperationType.Update && x.FullDocument.UserName.Contains("Alice")); filter &= Builders<ChangeStreamDocument<UserInfo>>.Filter.Exists("updateDescription.updatedFields.Password"); var pipeline = new IPipelineStageDefinition[] { PipelineStageDefinitionBuilder.Match(filter) }; using (var cursor = await collection.WatchAsync<ChangeStreamDocument<UserInfo>>(pipeline, options)) { while (await cursor.MoveNextAsync()) { foreach (var info in cursor.Current) { Console.WriteLine("Updated: " + info.FullDocument.UserName); } } }Si no le importa usar una biblioteca, todas las canciones y bailes anteriores se pueden evitar y las cosas se pueden resumir en lo siguiente:
var watcher = DB.Watcher<UserInfo>("on-alice-updates-password"); watcher.Start( eventTypes: EventType.Updated, filter: b => b.Where(x => x.FullDocument.UserName == "Alice") & b.Exists("updateDescription.updatedFields.Password")); watcher.OnChanges += docs => { foreach (var doc in docs) Console.WriteLine("Updated: " + doc.UserName); };consulte los documentos de MongoDB.Entities para obtener más información. descargo de responsabilidad: soy el autor de esa biblioteca.