MongoDB CHANGESTREAM в C # - PullRequest
       13

MongoDB CHANGESTREAM в C #

0 голосов
/ 24 октября 2018

Мне было интересно, использовал ли кто-нибудь из вас CHANGESTREAM.Я этот блок кода, чтобы посмотреть коллекцию, и она работает нормально.Я хотел бы знать, если есть способ проецировать только определенные поля из FullDocument, прежде чем вставить его в отдельную коллекцию.

ChangeStreamOptions options = new ChangeStreamOptions() { FullDocument = ChangeStreamFullDocumentOption.UpdateLookup };

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

using (var cursor = collection.Watch(pipeline,options))
{
    foreach (var change in cursor.ToEnumerable())
    {
        Console.WriteLine(change.OperationType + " " + "has been captured");
    }
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...