MongoDB ChangeStream LINQ筛选使用UpdateDescription报错的解决办法

需求 #

筛选ChangeStream文档，需满足两个条件：

• UpdateDescription.UpdatedFields中包含指定字段列表里的任意一个字段
• 文档的操作类型（OperationType）匹配指定值

尝试的代码及错误 #

尝试用LINQ表达式编写Match条件：

var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>()
    .Match(
(ChangeStreamDocument<BsonDocument> doc) =>
     doc.UpdateDescription.UpdatedFields.Any(c => fieldNameList.Contains(c.Name))
     &&
     doc.OperationType == _operationType);

运行时抛出错误：

System.NotSupportedException: 'Serializer for MongoDB.Driver.ChangeStreamUpdateDescription must implement IBsonDocumentSerializer to be used with LINQ.'

尝试传入ChangeStreamDocumentSerializer实例后，错误仍未解决。

解决方案 #

方法1：使用原生BsonDocument构造查询条件 #

绕过LINQ的序列化限制，直接用MongoDB原生查询语法构建匹配条件：

// 构建每个字段存在性检查的条件
var fieldFilters = fieldNameList.Select(field => 
    new BsonDocument($"updateDescription.updatedFields.{field}", new BsonDocument("$exists", true)));

// 组合操作类型匹配和字段存在的OR条件
var matchFilter = new BsonDocument
{
    { "operationType", _operationType.ToString() },
    { "$or", new BsonArray(fieldFilters) }
};

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

方法2：使用强类型FilterDefinition构建 #

如果偏好强类型写法，可以用Builders构造FilterDefinition：

// 构建每个字段的存在性筛选器
var fieldFilters = fieldNameList.Select(field => 
    Builders<ChangeStreamDocument<BsonDocument>>.Filter.Exists(doc => doc.UpdateDescription.UpdatedFields[field]));

// 组合操作类型匹配和字段存在的OR条件
var matchFilter = Builders<ChangeStreamDocument<BsonDocument>>.Filter.And(
    Builders<ChangeStreamDocument<BsonDocument>>.Filter.Eq(doc => doc.OperationType, _operationType),
    Builders<ChangeStreamDocument<BsonDocument>>.Filter.Or(fieldFilters)
);

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

原因说明 #

MongoDB的LINQ驱动无法将UpdateDescription.UpdatedFields.Any(...)这类表达式转换为有效的MongoDB查询语句，且ChangeStreamUpdateDescription的序列化器不支持这种LINQ操作场景，因此需要改用原生查询构造方式来实现需求。

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