聚合和分组

Question

尝试使用我的 .NET Core 项目对我的 MongoDB 集合进行一些分析。 （C# 驱动程序）

我的问题是按多个字段以及嵌套数组元素字段进行聚合和分组。

对于初学者，这里是我可以记录的示例 -

{
  "_id": ".....",
  "CampaignId": 1,
  "IsTest":false
  "Events": [
    {
      "EventId": 1,
      "IsFake": false
    },
    {
      "EventId": 1,
      "IsFake": true
    }
    {
      "EventId": 2,
      "IsFake": false
    }
  ]
}

我的最终目标是生成一个如下所示的分析报告-

[
  {
    "CampaignId": 1,
    "DocumentCountReal":17824,
    "DocumentCountTest":321,
    "EventCountReal":100,
    "EventCountFake":5,
    "Events": [
      {
        "EventId": 1,
        "IsFake": false,
        "Count": 50
      },
      {
        "EventId": 1,
        "IsFake": true,
        "Count": 5
      },
      {
        "EventId": 2,
        "IsFake": false,
        "Count": 50
      }
    ]
  },
  {
    "CampaignId": 2,
    "DocumentCountReal":1314,
    "DocumentCountTest":57,
    "EventCountReal":50,
    "EventCountFake":0,
    "Events": [
      {
        "EventId": 1,
        "IsFake": false,
        "Count": 25
      },
      {
        "EventId": 2,
        "IsFake": false,
        "Count": 25
      }
    ]
  }
]

只是为了向您展示我目前的立场，我发现了如何按一个字段分组哈哈... 示例 -

var result = collection.Aggregate().Group(c => c.CampaignId, r => new { CampaignId= r.Key, Count = r.Count()}).ToList();

找不到如何按嵌套数组元素字段（在示例中为 Event 中的 IsFake 属性）进行分组，并且通常无法构建我上面分享的结果。 令我惊讶的是，我在 google 中找不到很多相关问题..（特别是使用 c# 驱动程序）

非常感谢阅读

Answer 1

所以，最终找到了部分解决方案，我想我会分享 - 最大的问题是按嵌套数组的属性进行分组（在我最初的问题中，它是事件数组）。 为了实现这一点，我使用了 Unwind (https://docs.mongodb.com/manual/reference/operator/aggregation/unwind/) 仅供参考 - 我需要使用 PreserveNullAndEmptyArrays 选项，以免错过没有事件的文档。 另外，我做了一个额外的类，其中Events 属性是单个事件而不是列表，即在使用 Uwind 后反序列化文档。

我的第二个问题是如何在一次访问数据库中执行多个聚合，正如 Valijon 评论的那样，看起来$facet 是必需的，找不到适合我问题的示例。

我的解决方案示例 -

            IMongoDatabase db = MongoDBDataLayer.NewConnection();
            IMongoCollection<Click> collection = db.GetCollection<Click>("click");

            var unwindOption = new AggregateUnwindOptions<ClickUnwinded>() { PreserveNullAndEmptyArrays = true };


            var result = collection.Aggregate().Unwind<Click, ClickUnwinded>(c => c.Events, unwindOption)
                .Group(
                //group by
                c => new GroupByClass()
                {
                    CampaignId = c.CampaignId,
                    IsTest = c.IsTest,
                    EventId = c.Events.EventId,
                    IsRobot = c.UserAgent.IsRobot
                },
                r => new GroupResultClass()
                {
                    CampaignId = r.First().CampaignId,
                    IsTest = r.First().IsTest,
                    EventId = r.First().Events.EventId,
                    IsRobot = r.First().UserAgent.IsRobot,
                    Count = r.Count()
                }
                ).ToList();

如果有人有一个如何使用 c# 驱动程序来利用 facet 的示例，那就太好了。

编辑 - 因此，问题在于，如果文档有多个事件，则执行上述方法将多次计算同一个文档......所以我必须找到一种方法来进行多重聚合（第一次聚合必须在展开之前发生）或制作 2去数据库旅行。