Spring Data MongoDB聚合框架，异常访问组中的计算值

Question

我有一个行程集合，每个行程都有一个 startDateTime 和一个 completionDateTime 属性。

我正在尝试使用聚合框架来查找用户旅行的平均持续时间。

我的聚合看起来很简单，但它会引发异常。

下面有 3 个步骤，第一个只是匹配到特定 userId 的行程。 在管道的第二步中，我将我感兴趣的数据与新计算的每次旅行的持续时间一起投影。

我预计投影的持续时间在组步骤中可用，但我得到下面的 IllegalArgumentException。 Duration 不是我的 Trip 类的属性，但从我在文档中看到的示例来看，我认为不需要。 Duration 是我的分析类的一个属性。

TypedAggregation<Trip> aggregation = newAggregation(Trip.class, 
    match(Criteria.where("userId").is(aUserId)),

    project("completionDateTime", "startDateTime", "userId")
    .and("completionDateTime").minus("startDateTime").as("duration"),

    group("userId").avg("duration").as("averageDuration")
);
AggregationResults<Analytics> result = mongoTemplate.aggregate(aggregation, Analytics.class);

我相信持续时间的计算是正确的，就好像我省略了组步骤一样，我返回了一组文档并且它们都设置了持续时间。

java.lang.IllegalArgumentException: Invalid reference 'duration'!
    at org.springframework.data.mongodb.core.aggregation.ExposedFieldsAggregationOperationContext.getReference(ExposedFieldsAggregationOperationContext.java:78)
    at org.springframework.data.mongodb.core.aggregation.GroupOperation$Operation.getValue(GroupOperation.java:367)
    at org.springframework.data.mongodb.core.aggregation.GroupOperation$Operation.toDBObject(GroupOperation.java:363)
    at org.springframework.data.mongodb.core.aggregation.GroupOperation.toDBObject(GroupOperation.java:308)
    at org.springframework.data.mongodb.core.aggregation.Aggregation.toDbObject(Aggregation.java:247)

我正在使用 1.3.4.RELEASE

有什么建议吗？

Answer 1

升级到 1.4.1 后，我能够使用以下方法获得所需的结果：

.andExpression("completionDateTime - startDateTime").as("duration")

Answer 2

您似乎遇到了https://jira.spring.io/browse/DATAMONGO-838，所以在它修复之前，您可能需要找出一种不同的方法来做您需要的事情。

在使用 js 的 mongo shell 中，您不需要 $project 字段，您可以直接将计算表达式替换为组，如下所示：

db.collection.aggregate( {$match:{ your-match } },
     { $group : { 
         _id : "$userId",
         avgDuration : { $avg : {$subtract:["$completionDateTime","startDateTime"]}},
     } } );

在 Spring 中可能可以返回表达式以执行此操作。如果没有，您的另一个选择是通过 Java 驱动程序将聚合直接传递给 MongoDB，绕过 Spring，直到修复错误。