展开并忽略重复后的组元素-MongoDB聚合

Question

我使用聚合来展开一个数组，并按数组的每个元素分组，以对一些对应的值求和。

我的收藏是：

/* 1 */
{
    "_id" : ObjectId("59ce411c2708c97154d1319b"),
    "sourceMediumPath" : [ 
        {
            "nodeValue" : "(direct) / (none)"
        }, 
        {
            "nodeValue" : "(direct) / (none)"
        }
    ],
    "totalConversions" : 1,
    "totalConversionValue" : 171.6,
}

/* 2 */
{
    "_id" : ObjectId("59ce411c2708c97154d136a0"),
    "sourceMediumPath" : [ 
        {
            "nodeValue" : "google / cpc"
        }, 
        {
            "nodeValue" : "(direct) / (none)"
        }, 
        {
            "nodeValue" : "google / cpc"
        }
    ],
    "totalConversions" : 1,
    "totalConversionValue" : 151.8,
}

我想按sourceMedium分组。nodeValue和sum“totalConverions”和“totalConversionValue”，而不使用重复元素。

例如，通过使用展开、分组和和：

aggregation = Aggregation.newAggregation(
                    Aggregation.unwind("sourceMediumPath"),
                    Aggregation.group("sourceMediumPath.nodeValue")
                            .sum("totalConversions").as(Variables.TOTAL_CONNVERSIONS)
                            .sum("TotalConversionValue").as(Variables.TOTAL_CONVERSION_VALUE),

                    Aggregation.project("sourceMediumPath.nodeValue")
                            .andInclude(Variables.TOTAL_CONNVERSIONS, Variables.TOTAL_CONVERSION_VALUE)

对于“nodeValue”：（direct）/（none）“TotalConversions之和等于3，对于“google/cpc”之和等于1。因为它在执行展开操作时复制totalConversions和totalConversions。

有任何解决方案可以忽略重复，并且每个文档只有一个值。

我怎么能那么做？

Answer 1

在Spring Data中，聚合投影管道中的相交数组通过应用相同的数组来完成这项工作。

aggregation = Aggregation.newAggregation(
               Aggregation.project().and("sourceMediumPathnodeValue").intersectsArrays("sourceMediumPathnodeValue").as("Intersection").andInclude(...),
                    Aggregation.unwind("Intersection"),
                    Aggregation.group("Intersection")
                            .sum("totalConversions").as("totalConversions")
                            .sum("TotalConversionValue").as(TotalConversionValue"),
                    Aggregation.project("sourceMediumPath.nodeValue")
                            .andInclude("totalConversions", TotalConversionValue")

                        new OutOperation("OutputCollection")
                ).withOptions(Aggregation.newAggregationOptions().allowDiskUse(true).build());

非常感谢你的帮助

Answer 2

您可以使用$addField在$unroll阶段之前添加$addField以使用$setIntersect创建一个唯一值数组，并将此字段展开如下：

db.collection.aggregate( [
    { $addFields: {
        sourceMediumUniquePath: { $setIntersection: [ 
            "$sourceMediumPath", 
            "$sourceMediumPath" 
        ] }
    } },
    { $unwind: "$sourceMediumUniquePath" },
    ... rest of the pipeline ...
])

更新：

如果不支持$添加字段，则可以将其替换为$项目阶段。唯一的缺点是，您需要列出在以后阶段需要的所有字段。例如。：

db.collection.aggregate( [
    { $project: {
        sourceMediumUniquePath: { $setIntersection: [ 
            "$sourceMediumPath", 
            "$sourceMediumPath" 
        ] },
        totalConversions: 1,
        totalConversionValue: 1
    } },
    { $unwind: "$sourceMediumUniquePath" },
    ... rest of the pipeline ...
])