我正在尝试使用c驱动程序创建一个mongodb聚合管道,该驱动程序包括redact和一个项目。我尝试了下面所示的几种方法,但在每种情况下都只执行管道的第一阶段。appendStage似乎不追加下一个阶段。那么,如何使用c mongodb驱动程序使一个redact后跟一个项目呢?请注意,fluent接口并不直接支持redact,而是显示了另一篇文章,使用下面的代码来完成它,这对第一阶段是有效的。
我使用的是2.4.3版本的C驱动程序和MongoDB 3.4.4版本

string redactJson = System.IO.File.ReadAllText(@"redactTest.json");
string projectJson = System.IO.File.ReadAllText(@"projectTest.json");

var collection = Database.GetCollection<BsonDocument>("Forecasts");

var redact = BsonDocument.Parse(redactJson);
var project = BsonDocument.Parse(projectJson);


var aggregatonPipeline = collection.Aggregate();
aggregatonPipeline.AppendStage<BsonDocument>(redact);
aggregatonPipeline.AppendStage<BsonDocument>(project);

var list = aggregatonPipeline.ToList();

或者类似的代码
var pipeline = collection.Aggregate().AppendStage<BsonDocument>(redact);
pipeline.AppendStage<BsonDocument>(project);
var list = pipeline.ToList();

我的聚合json如下所示
redacttest.json版本:
{
    $redact: {
       $cond: {
         if: {
             $gt: [{ $size: { "$setIntersection": [ "$tags", ["STLW", "G"]]}}, 0]
         },
         then: "$$DESCEND",
         else: "$$PRUNE"
      }
   }
}

项目测试.json
{
  "$project":
  {
    "_id": 0,
    "title": 1,
    "year": 1,
    "subsections.subtitle": 1,
    "subsections.content":  1
  }
}

源文件是
{
  _id: 1,
  title: "123 Department Report",
  tags: [ "G", "STLW" ],
  year: 2014,
  subsections: [
    {
      subtitle: "Section 1: Overview",
      tags: [ "SI", "G" ],
      content:  "Section 1: This is the content of section 1."
    },
    {
      subtitle: "Section 2: Analysis",
      tags: [ "STLW" ],
      content: "Section 2: This is the content of section 2."
    },
    {
      subtitle: "Section 3: Budgeting",
      tags: [ "TK" ],
      content: {
      text: "Section 3: This is the content of section3.",
       tags: [ "HCS" ]
     }
   }
 ]
}

最佳答案

collection.Aggregate()公开fluent聚合接口,并通过方法链接将阶段附加到管道。
有点像

var pipeline= collection.Aggregate().AppendStage<BsonDocument>(redact).AppendStage<BsonDocument>(project);
var list = pipeline.ToList();

每次添加一个阶段时,您的用法将覆盖前面的阶段。

10-06 10:16