配置ChangeStreamCursor时使用Mpipeline报错，如何监听指定MongoDB数据库变更流？

异常原因是MongoDB的LINQ驱动无法直接处理DatabaseNamespace对象的序列化——它的序列化器未实现IBsonDocumentSerializer，导致你在LINQ表达式中访问change.DatabaseNamespace.DatabaseName时抛出错误。

直接用BsonDocument构建匹配阶段即可解决，绕开LINQ的序列化限制：

var client = new MongoClient("<My connection string>");
var watchedDatabaseNames = new List<string> { "DB1", "DB2" };
var options = new ChangeStreamOptions { FullDocument = ChangeStreamFullDocumentOption.UpdateLookup };

// 直接针对Change Stream原始文档的`ns.db`字段进行匹配
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>()
    .Match(new BsonDocument("ns.db", new BsonDocument("$in", watchedDatabaseNames)));

var cursor = client.Watch(pipeline, options);

原理说明 #

Change Stream返回的原始文档中，数据库名称存储在ns.db字段下（ns是命名空间对象，包含db和coll两个子字段），直接用BsonDocument指定这个字段路径，就能正确筛选出目标数据库的变更通知，同时避开LINQ对DatabaseNamespace对象的序列化问题。

额外注意 #

确保你的MongoDB服务器版本在4.0及以上，只有这个版本及以后才支持集群级别的Change Stream（也就是通过client.Watch()监听全集群的变更）。

内容的提问来源于stack exchange，提问作者EuroEager