0

我正在尝试将 MongoDB 中的更改流缩小到与文档的 _id 匹配的特定文档，因为我在一个集合中有许多文档。任何人都知道如何在C#中做到这一点？这是我尝试无济于事的最新消息：

{
    var userID = "someIdHere";
    var match = new BsonDocument
    {
        {
            "$match",
            new BsonDocument
            {
                {"_id", userID}
            }
        }
    };
    var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<Class>>().Match(match);

    var options = new ChangeStreamOptions { FullDocument = ChangeStreamFullDocumentOption.UpdateLookup };
    var cursor = collection.Watch(pipeline, options).ToEnumerable();
    foreach (var change in cursor)
    {
        Debug.WriteLine(change.FullDocument.ToJson());
        Debug.WriteLine(change.ResumeToken + " " + change.OperationType);
    }
}

如果我将光标更改为您在下面看到的内容，它会起作用，但是当文档中存在任何 _id 的活动时，它会返回世界并返回更改流。那不是我想要的。

var cursor = collection.Watch().ToEnumerable();
4

1 回答 1

3

在远近搜索之后，我能够将我在网上找到的其他问题的零碎信息拼凑起来，并提出了以下解决方案。它就像一个魅力！

我不仅能够过滤更改流，使其仅识别更新，而且我能够将流缩小到特定文档 _id 并使其更精细地找到对该 _id 名为 LastLogin 的字段的特定更改。这是我想要的，因为默认的更改流返回了集合上发生的任何更新。

我希望这可以帮助遇到与我相同的问题的人。干杯。

{
    var db = client.GetDatabase(dbName);
    var collectionDoc = db.GetCollection<BsonDocument>(collectionName);
    var id = "someID";

    //Get the whole document instead of just the changed portion
    var options = new ChangeStreamOptions
    {
        FullDocument = ChangeStreamFullDocumentOption.UpdateLookup
    };

    //The operationType of update, where the document id in collection is current one and the updated field
    //is last login.
    var filter = "{ $and: [ { operationType: 'update' }, " +
                 "{ 'fullDocument._id' : '" + id + "'}" +
                 "{ 'updateDescription.updatedFields.LastLogin': { $exists: true } } ] }";

    var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>().Match(filter);

    var changeStream = collectionDoc.Watch(pipeline, options).ToEnumerable().GetEnumerator();

    try
    {
        while (changeStream.MoveNext())
        {
            var next = changeStream.Current;
            Debug.WriteLine("PRINT-OUT:" + next.ToJson());
        }
    }
    catch (Exception ex)
    {
        Debug.WriteLine("PRINT-OUT: " + ex);
    }
    finally
    {
        changeStream.Dispose();
    }
}
于 2018-06-08T05:03:42.447 回答