如何在C#中实现MongoDB聚合与更新结合的操作

我无法找到将以下MongoDB命令转换为C#代码的方法：

db.Queue.aggregate( 
[ 
   { $match: { "Processed": false } }, 
   { $sort: { "LastTimeChanged": 1  } }, 
   { $limit: 1 }, 
   { $set: { "WorkerName": "WORKER_NAME", "Processed": true }  }, 
   { "$merge": "Queue"  }])

我遇到的问题在于$set和$merge命令：

• $set：在MongoDB.Driver for .NET中，我找不到聚合命令对应的$set操作
• $merge：现有$merge命令示例均为集合合并场景，我不知如何在此场景下使用API中的Merge方法
  恳请各位解惑！

解决方案 #

1. 聚合中$set的实现 #

在MongoDB.Driver里，聚合阶段的$set对应AddFields方法（新版本驱动也支持直接用Set），它可以实现添加或更新文档字段的效果，和原生$set行为完全一致。

2. 聚合中$merge的实现 #

$merge用于将聚合结果写回目标集合，这里要写回原Queue集合，只需在Merge方法中指定目标集合名称即可，无需复杂配置，默认会按_id匹配文档完成更新。

完整C#代码示例 #

假设你已定义对应集合的实体类QueueItem，代码如下：

using MongoDB.Driver;

// 集合对应的实体类
public class QueueItem
{
    public bool Processed { get; set; }
    public DateTime LastTimeChanged { get; set; }
    public string WorkerName { get; set; }
    // 其他字段根据实际需求补充
}

// 初始化客户端与集合
var mongoClient = new MongoClient("mongodb://localhost:27017");
var db = mongoClient.GetDatabase("你的数据库名");
var queueCollection = db.GetCollection<QueueItem>("Queue");

// 构建聚合管道
var pipeline = new PipelineDefinition<QueueItem, QueueItem>(new[]
{
    // $match 筛选未处理的文档
    PipelineStageDefinitionBuilder.Match<QueueItem>(q => !q.Processed),
    // $sort 按LastTimeChanged升序排序
    PipelineStageDefinitionBuilder.Sort(Builders<QueueItem>.Sort.Ascending(q => q.LastTimeChanged)),
    // $limit 只取第一条
    PipelineStageDefinitionBuilder.Limit<QueueItem>(1),
    // $set 更新字段
    PipelineStageDefinitionBuilder.AddFields(
        new FieldsDefinitionBuilder<QueueItem>()
            .Set(q => q.WorkerName, "WORKER_NAME")
            .Set(q => q.Processed, true)),
    // $merge 将结果写回Queue集合
    PipelineStageDefinitionBuilder.Merge<QueueItem>(new MergeOptions<QueueItem>
    {
        Into = "Queue"
    })
});

// 执行聚合操作
await queueCollection.Aggregate(pipeline).ToListAsync();

补充说明 #

• 若使用2.15+版本的MongoDB.Driver，也可以直接用Set方法构建$set阶段，写法更简洁：PipelineStageDefinitionBuilder.Set<QueueItem>(q => q.WorkerName, "WORKER_NAME").Set(q => q.Processed, true)
• 如果需要自定义$merge的匹配规则或冲突处理逻辑，可以在MergeOptions中配置On（匹配字段）、WhenMatched（匹配时的行为）等参数。

内容的提问来源于stack exchange，提问作者Paulo Aboim Pinto