Mongo DB:聚合阶段$group后如何获取原始文档？
在MongoDB中，聚合操作是对数据进行处理和分析的重要工具。在聚合操作中，$group阶段用于对数据进行分组，并对每个分组进行计算和聚合。如果在$group阶段后需要获取原始文档，可以使用$push操作符将原始文档保存在一个数组中。
具体操作如下：
- 在$group阶段中，使用$push操作符将原始文档保存在一个数组中。例如，假设我们要按照某个字段进行分组，并且需要获取每个分组的原始文档，可以使用以下聚合操作：
db.collection.aggregate([
{
$group: {
_id: "$field",
documents: { $push: "$$ROOT" }
}
}
])在上述聚合操作中，$field是用于分组的字段，$$ROOT表示当前文档的引用。
- 执行上述聚合操作后，将会得到一个包含分组结果的数组。每个分组的结果都包含一个_id字段和一个documents字段，其中_id字段表示分组的依据，documents字段是一个数组，包含了该分组的所有原始文档。
通过以上操作，我们可以在$group阶段后获取到原始文档。这样可以方便地对聚合结果进行进一步处理或分析。
对于MongoDB的聚合操作，腾讯云提供了云数据库MongoDB（TencentDB for MongoDB）产品，它是一种高性能、可扩展的分布式数据库服务。您可以通过腾讯云MongoDB产品来存储和处理数据，并使用聚合操作来进行数据分析和计算。
更多关于腾讯云MongoDB产品的信息和介绍，请访问以下链接：
请注意，以上答案仅供参考，具体操作和产品选择应根据实际需求和情况进行。
相关·内容
我正在我的mongo集群上运行一个groupBy query。我正在使用在线工具。运行查询后，我将得到一个错误。数据大小很大。有绕道的路吗？
// SQL query
SELECT COUNT(*) AS count FROM db_name
WHERE version="v2"
GROUP BY id
// Mongo query
db.db_name.group({
"key": {
"id": true
},
"initial": {
"count": 0
},
"reduce&
浏览 7提问于2020-05-19得票数 0
回答已采纳
2回答
我有一个想要查询的mongoDB。我知道如何在sql中这样做，但不确定如何在MongoDB中这样做。
select distinct value, type, array_agg(distribution) as distributions
from t
group by value, param_type;
我正在尝试，但不断地出错：
db.getCollection('test').aggregate([
{
$group: {
_id: {
"type": "$type",
"
浏览 5提问于2021-03-25得票数 0
回答已采纳
嗨:我在用聚合查询替换mongo独特的“原生”函数时遇到了一些问题。 在我的例子中，我的查询如下： db.collection.distinct('stuff.shape') 然后，mongo返回一个具有不同object.field值的数组，如下所示 ['square','triangle','circle'] 但是用聚合体遮蔽 db.collection.aggregate([
{ $match:{ 'stuff.shape':{$exists: true} } },
{ $group:{ '
浏览 49提问于2020-07-07得票数 0
回答已采纳
我正在尝试使用多关键字索引来按另一个关键字查找最新记录。我似乎不能让它表现出来。
在伪sql中，我会说
create table my_table (user_id int, post_time timestamp, content text);
create index my_index (user_id,post_time) on my_table;
然后，我可以点击索引，为每个用户找到最新的post_time
select user_id,max(post_time) from my_table group by user_id
即使有数百万条记录，数据也将来自索引，而我们根本不会命中表
浏览 1提问于2015-02-06得票数 1
我读过mongo文档，似乎有点困惑，$filter和$redact操作符是否相同，如果不是，如何相同？我已经使用它们来获取文档中数组的子集。$redact似乎是一样的，但mongo的定义似乎不同。然而，mongo站点上的示例演示了$redact的数组子集操作。
我很清楚$filter运算符，它只适用于数组，而对$redact不清楚。
与$filter相比，$redact的优势是什么？它的用例是什么？
例如：
db.shirts.aggregate([{
$redact: {
$cond: {
'if': {
$or:
浏览 3提问于2018-03-31得票数 1
我有一个活动行集合的示例
{
"_id" : ObjectId("5ec90b5258a37c002509b27d"),
"user_hash" : "asdsc4be9fe7xxx",
"type" : "Expense",
"name" : "Lorem",
"amount" : 10000,
"date_created" : 1590233938
}
我想用这个聚合代码收集活动的总和。
db.a
浏览 1提问于2020-07-19得票数 0
回答已采纳
1回答
也许有人能帮我。我在mongodb中有下表，我需要执行以下计算：
赔率：
高
平均
低
对于每一个概率，必须应用一个乘数。
示例：
高概率：值* 0.87
平均概率：值* 0.5
低概率：值* 0.06
我在db mongo中进行了以下查询，但只能应用一个乘法器。我无法区分每个概率乘以上述值。
db.teste.aggregate(
{
$match: {
$and: [
{
"converted_fields.Probabilidade de fechamento&
浏览 4提问于2020-08-21得票数 0
回答已采纳
1回答
有两个集合：Alerts、和AlertTypes。Alerts集合有一个名为: alertTypeId的字段，它是AlertTypes集合的查找/外键。
我需要优化以下查询，通过加入相应的集合，从Alerts集合以及AlertType名称获取数据。
我使用聚合函数如下：
db.Alerts.aggregate([{
"$match": {
"status": {
"$ne": -1
},
"type": 4
}
}, {
"$l
浏览 3提问于2021-03-17得票数 1
我正在尝试从rmongodb访问mongodb聚合框架。它应该可以通过mongo.command()获得，但是我不能正确地使用bson。
下面是一个可复制的示例。在R中，设置一个测试集合：
mongo <- mongo.create()
db <- "test"
ns <- "test.people"
buf <- mongo.bson.buffer.create()
mongo.bson.buffer.append(buf, "name", "John")
mongo.bson.buffer.appen
浏览 0提问于2013-05-04得票数 4
回答已采纳
2回答
我试过几个密码，但都没成功。在数据库中的示例中，一个有先决条件，一个没有先决条件，我想找出主题的总数，其中没有先决条件：
db.Subject.insert(
{
"_id":ObjectId(),
"subject":{
"subCode":"CSCI321",
"subTitle":"Final Year Project",
"credit":6,
"type":"Core
浏览 10提问于2020-11-18得票数 2
回答已采纳
我正在使用脚本来删除mongo上的副本，它在一个包含10个项目的集合中工作，我用它作为测试，但是当我使用600万个文档的实际集合时，我会得到一个错误。
这是我在Robomongo (现在称为)中运行的脚本：
var bulk = db.getCollection('RAW_COLLECTION').initializeOrderedBulkOp();
var count = 0;
db.getCollection('RAW_COLLECTION').aggregate([
// Group on unique value storing _id value
浏览 30提问于2017-05-24得票数 34
回答已采纳
1回答
聚合不一致地打印不同的值。
、、、、
我有下面的代码片段，它应该使用检索帐户的总计数。
TypedAggregation<Account> agg = Aggregation.newAggregation(Account.class,
group("user.id"),
group().count().as("total"));
AggregationResults<AccountTotal> result = mongos.aggregate(agg, AccountTotal.class);
AccountTotal account =
浏览 2提问于2015-04-28得票数 1
我有一个问题，如何从mongo数据库中获取特定数据。数据库中的数据非常大，其中有许多对象。这些对象具有以下体系结构：
{
"_id": ObjectId("XXXX"),
"app_id": "XXXXXX",
"title": "The title",
"os": "OS",
"crash": [{
"crash_reason
浏览 0提问于2018-07-13得票数 0
回答已采纳
2回答
如果我执行计数查询，则在<2秒内得到结果
db.coll.find({"A":1,"createDate":{"$gt":new Date("2011-05-21"),"$lt":new Date("2013-08-21")}}).count()
这使用了以下索引
db.coll.ensureIndex({"A":1,"createDate":1})
类似地，有4列A、B、C、D(值总是0或1)，对这些列我运行4个计数查询，并在<10秒内获得结果。
我查看
浏览 5提问于2014-02-21得票数 5
1回答
首先，我们只是从Server迁移到Mongodb。我有一个包含字段TFN, Impressions的集合。我需要在mongo中转换sql查询，但一时陷入困境。
场景是我需要从集合中选择一个top 5 impressions，它是group by on the basis of tfns
Select Top 5 a.TFN, a.MaxImpression as MaxCount from (
Select TFN, Max(Impressions) MaxImpression
from tblData
Where TFN in (Select TFN From @tmpTF
浏览 2提问于2017-04-24得票数 2
回答已采纳
1回答
Aggregation agg = Aggregation.newAggregation(
other operations ////
Aggregation.group("name") .first("$$ROOT").as("doc").count().as("Total"),
other operations ////
);
这里我们将count存储为group操作的值，并将其存储在字符串变量"Total“中，如何以int格式获取count的值？
注意:我使用的是Mongo模板。
浏览 18提问于2021-05-19得票数 0
我正在使用：
db.version()
3.2.3
版本()
3.2.0-17-gde480c0
db.getCollection('events').aggregate([
{ $concat: [ "$element", " - ", "$Eventtype" ] }
])
出现以下错误：
"assert: command failed: {
"ok" : 0,
"errmsg" : "Unrecognized pipeline stage nam
浏览 9提问于2016-09-09得票数 0
回答已采纳
2回答
以下是查询：
const tags = await mongo
.collection("positive")
.aggregate<{ word: string; count: number }>([
{
$lookup: {
from: "search_history",
localField: "search_id",
foreignField: "search_id",
浏览 5提问于2022-09-26得票数 0
回答已采纳
我在一个web应用程序的前端有过滤器，其中大多数是多选择过滤器。
我正在尝试编写一个mongo聚合查询，它处理两种场景。
用户从多选择下拉筛选器中选择值.查询将获取所选值并将相关数据返回给客户端。A用户不会从多选择下拉筛选器中选择任何内容。在这种情况下，查询应该返回所有数据.
查询应该如下所示。显然，下面的查询不起作用。
db.hospitals.aggregate([
{
$match: {
hosp_name: {
$cond: {
if: {
浏览 3提问于2021-08-31得票数 0
4回答
在以下查询中：
db.orders.aggregate([{ $match : { status: "A"}, { $limit: 5} }]);
如何在$match之后，但在应用$limit之前，获得文档的计数？
我仍然希望返回一个由5个文档组成的数组。但是，如果我使用$group，它似乎不会保留文档数组。这能在一个电话里做吗，还是我要打两个电话？
浏览 2提问于2014-09-18得票数 21
回答已采纳
在使用Mongo驱动程序时，是否有方法将聚合结果输出到集合？在mongo中运行聚合时，通常使用$out : "collection_name"完成，如下所示：
db.collection.aggregate([
{$match},
{$group},
{
$out : "newcollection"
}
]);
在使用PHP驱动程序时，如下所示：
$m = new MongoClient("localhost");
$c = $m->selectDB($this->mon
浏览 1提问于2015-05-22得票数 0
回答已采纳
2回答
如果Mongo查询没有返回任何输入，我在查询中增加了group stages的数量。下面是我正在使用的查询的片段，
.group({
_id: "$date",
count: {
$sum: 1
},
})
/*
.group({
_id: "$joinDate",
count: {
$sum: 1
},
})
.group({
_id: "$applyDate",
count: {
$sum: 1
},
})*/
浏览 3提问于2019-09-17得票数 0
3回答
我在mongodb中的集合与SQL中的下表类似：
情绪(公司，情绪)
现在，我需要执行如下查询：
SELECT
Company,
SUM(CASE WHEN Sentiment >0 THEN Sentiment ELSE 0 END) AS SumPosSenti,
SUM(CASE WHEN Sentiment <0 THEN Sentiment ELSE 0 END) AS SumNegSenti
FROM Sentiments
GROUP BY Company
我应该怎么做才能在Mongo中编写这个查询？我被以下问题困扰了：
db.Sentiments.ag
浏览 2提问于2012-12-31得票数 61
回答已采纳
字段已添加，但随后消失。以下是mongo shell中的代码：
> db.users.aggregate([{$addFields:{totalAge:{$sum:"$age"}}}])
{ "_id" : ObjectId("5acb81b53306361018814849"), "name" : "A", "age" : 1, "totalAge" : 1 }
{ "_id" : ObjectId("5acb81b5330636101881484a&
浏览 1提问于2018-04-10得票数 0
我试图根据mongo的聚合方法获得一组结果，并根据返回来尝试在所有这些结果中添加一个属性。聚合方法为我提供了最高的no。在一个月内从某一综合体的某一特定销售点销售。我想将属性highestSales添加到它返回的文档中。我的问题是：
var shops = db.data.aggregate([
{
$group: {
_id: "$shopName",
Sales: { $max: "$Sales" }
}
}
]);
商店变量提供了5个商店名称，如下所示：
{
浏览 1提问于2015-03-30得票数 10
回答已采纳
我有一个包含书籍的数据库。它有“作者”、“标题”、“年份”和“书籍类型”等字段。假设我想在我的网站上描述当前数据库中的数据，例如图书总数、不同作者的总数、每个作者的总图书数等等。
我应该在Mongo做几个单独的聚合，还是可以组合它们。现在我会做这样的事
db.aggregate([
{
$group : {
_id : "$author",
details: {
$push : {
id:"$_id"
浏览 2提问于2022-06-13得票数 1
回答已采纳
我试图使用以下文档查询MongoDB集合(我无法控制)，这些文档用作每个作业定义的作业日志：
{
"definition": ...,
"jobs": [ // sequential
{
"time": ...,
"result": "success"
},
{
"time": ... (after previous),
"resul
浏览 3提问于2016-05-26得票数 2
我正在尝试通过rmongodb中的操作在组中执行sum。我求和的“列”包含NaN值，导致我的sum返回NaN。在运行group by命令之前，我想使用$project将NaNs替换为零，但我被卡住了。
这将产生虚拟数据(在mongo控制台中)：
db.NAtest.insert({ y : 1, x : 1})
db.NAtest.insert({ y : 1, x : 2})
db.NAtest.insert({ y : 2, x : 3})
db.NAtest.insert({ y : 2, x : 4})
db.NAtest.insert({ y : 2, x : NaN})
这将产生所
浏览 0提问于2013-07-12得票数 4
回答已采纳
2回答
这是一个技术性能问题：
我有这样的疑问
db.collection.aggregate([
{$match:{...}},
{$group:{...}},
{$group:{...}},
{$project:{...}},
{$sort:...}
])
但是，如果我想设置限制，则在查询的最后使用$limit
db.collection.aggregate([
{$match:{...}},
{$group:{...}},
{$group:{...}},
{$project:{...}},
{$sort:...},
浏览 2提问于2015-07-17得票数 1
回答已采纳
2回答
我有一个表示消息线程的架构。所以mongo数据库中的每个文档看起来都是这样的：
{
id: "thread_id",
participants: ["user1", "user2"],
unReadMessageCounts: [
{
participant: "user1",
count: 5
},
{
participant: "user2",
浏览 3提问于2015-11-05得票数 2
回答已采纳
我是mongodb的新手，第一次尝试了聚合。在这里，我试图得到每15分钟分组的推文数量。当我试图在mongo控制台中运行以下查询时，会得到以下错误：
管道级规范对象必须精确地包含一个字段。
db.hashtag.aggregate([
{ "$group": {
"_id": {
"year": { "$year": "$tweettime" },
"dayOfYear": { "$dayOfYear&#
浏览 2提问于2017-02-14得票数 37
回答已采纳
我试图找出这段代码失败的原因：
db.restaurants.drop();
db.restaurants.insertMany( [
{ "_id" : 1, "borough" : "Manhattan"},
] );
db.restaurants.createIndex({
"borough": "text"
})
db.restaurants.aggregate([
{ $match: { $text: { $search: "a" } } },
{ $sort: {s
浏览 5提问于2021-03-07得票数 1
回答已采纳
1回答
我，我需要使用$sample命令：
// Get one random document from the mycoll collection.
db.mycoll.aggregate(
{ $sample: { size: 1 } }
)
但是，如果我需要过滤文档，然后随机抽取一个文档呢？
我正在处理文件，这些文件还没有用
query = {'start_time': {'$exists': False}}
hp_entries = mongo.hyperparameters_collection.find(query)
我怎么处理随机的？
浏览 4提问于2017-11-21得票数 9
回答已采纳
db.students.aggregate([
{ $unwind: "$details" },
{
$group: {
_id: {
sid: "$details.student._id",
statuscode: "$details.studentStatus.statusCode"
},
total: { $sum: 1 }
}
}
]);
查询工作正常，需要转换为mongo模板。
样本文件：
{
"_id" :
浏览 11提问于2020-01-08得票数 1
4回答
当我尝试添加具有特定值的新字段时，它在mongo上运行得很好：
db.getCollection('collName').aggregate([
{ "$group" : { "_id" : "$idcpt" , "sum" : { "$sum" : "$val"}}},
{$addFields : {idcpt : 1092}}
])
但是当我尝试使用org.springframework.data.mongodb.core.aggregation.Aggregation在春季实现
浏览 0提问于2018-12-04得票数 0
回答已采纳
我正在使用mongo中的一个示例，我对此做了一些修改：
db.books.aggregate(
[
{ $group : { _id : "$genre", books: { $push: "$$ROOT" } } }
]
)
此查询将按类型返回一系列书籍。
我想要定制它一点，这样我就不会得到额外的数据。下面的示例将是一个虚拟示例，但我很好奇它是否可以在mongo中实现。我希望我的聚合返回一个组数组，如果genre是“悲剧”，那么只会获取一本书，并且会有一个booksCount字段，而在所有其他情况下，books将是一个数组，而不会有一个b
浏览 1提问于2019-02-05得票数 0
回答已采纳
1回答
有人能指导我在Java中进行以下Mongo查询的聚合查询吗？我正在试着总结汽车每天所覆盖的距离。有一些重复的记录(我无法消除)，所以我必须使用组按来过滤掉它们。
db.collection1.aggregate({ $match: { "vehicleId": "ABCDEFGH", $and: [{ "timestamp": { $gt: ISODate("2022-08-24T00:00:00.000+0000") } }, { "timestamp": { $lt: ISODate("2022-08-
浏览 4提问于2022-10-26得票数 0
3回答
有没有可能在Mongo DB中使用2个或更多类似于SQL查询的集合来编写联合查询？
我使用的是spring mongo模板，在我的用例中，我需要根据一些条件从3-4个集合中获取数据。我们可以在一次操作中实现这一点吗？
例如，我有一个名为"circuitId“的字段，它在所有4个集合中都存在。我需要从所有4个集合中获取该字段与给定值匹配的所有记录。
浏览 0提问于2017-09-07得票数 8
回答已采纳
3回答
MongoDB中是否有用于聚合框架的解释函数？我在文档中看不到它。
如果没有，是否有其他方法可以检查查询在聚合框架中的执行情况？
我知道只要找到你就行
db.collection.find().explain()
但是对于聚合框架，我得到了一个错误
db.collection.aggregate(
{ $project : { "Tags._id" : 1 }},
{ $unwind : "$Tags" },
{ $match: {$or: [{"Tags._id":"tag1"},{"Tags._
浏览 0提问于2012-10-03得票数 133
回答已采纳
1回答
我有一个mongo，它看起来像这样->
集合名称:用户
{ username:'something'
_id : ObjectId(someID1)
acl : { users : [ObjectId(someID1),ObjectId(someID2),ObjectId(someID3)] , group : [grpID4,grpID5,grpID6] }
.
.
.
}
我希望有一个聚合查询，它在所有文档中查找db.users.acl.users，并找到每个唯一objectID的计数。
这就像添加users.acl.users的所有数组，然后在p
浏览 0提问于2014-07-22得票数 0
回答已采纳
我有一个带有索引字段country的集合，我正在尝试计算每个国家有多少文档，如下所示： db.collection.aggregate([
{"$group" : {_id:"$,country", count:{$sum:1}}}
]) 这给出了预期的结果，但是，我注意到它没有使用创建的索引并扫描所有文档。这对于mongo来说是正常的吗?如果是的话，我该如何让它使用索引呢？ "executionStats" : {
"executionSuccess" : true,
浏览 33提问于2020-09-25得票数 0
我正在用mongo shell编写一个$or查询
db.collectionName.find({$or:[{ fullName: { $regex: "a",$options:"i"}},{ fullName: { $regex: "b",$options:"i"}}]}).pretty();
它为我提供了与a或b的并集匹配的文档。但是我们还能找到查询的工作和结果是哪个值吗？例如，对于第一个正则表达式，即"a“，我得到一个单独的结果；对于另一个正则表达式，即"b”，我得到一个单独的结果
浏览 0提问于2021-02-08得票数 0
1回答
我有一个带有playerId字段的支付收集，这是个人收集的_id键。我需要数一次，一个人的最高报酬是多少，并将价值保存到人的文档中。我现在就是这样做的：
db.Person.find().forEach( function(person) {
var cursor = db.Payment.aggregate([
{$match: {playerId: person._id}},
{$group: {
_id:"$playerId",
maxp: {$max:"$amount"
浏览 2提问于2016-11-18得票数 0
回答已采纳
我试图在mongoDB集合中分页嵌套文档。
这是我的数据的样本。我添加了uid字段，其值为mongo ObjectId，希望它将指向itemInfo数组中的下一个对象。
const item = {
_id: ObjectID,
name: 'Test',
itemInfo : [
{
uid: "ObjectID",
itemData: [{}, {}]
},
{
uid: "ObjectID",
itemData: [{}, {}]
},
{
浏览 4提问于2022-06-01得票数 0
1回答
我希望在Mongo文档中找到嵌套字段的所有唯一值的频率计数器。
更确切地说，如果我收集的是db‘’sample‘，由以下文件组成-
{'a' : 1, 'b' : {'c' : 25, 'd' : "x", 'e' : 36}},
{'a' : 2, 'b' : {'c' : 5, 'd' : "xx", 'e' : 36}},
{'a' : 33, 'b' : {&#
浏览 1提问于2019-03-24得票数 1
回答已采纳
在Rails应用程序中，我有一个事件集合，每个事件都有一个被邀请者列表。我希望有一个单一的扁平化名单邀请的整个名单。一个简单的.map不是一个选择，因为有成千上万的活动和被邀请者一样多……
class Event
include Mongoid::Document
include Mongoid::Timestamps
has_many :invitees
end
我尝试通过以下代码使用Map/Reduce：
map = %Q{
function() {
var event = this;
this.invitees.forEach(function(invi
浏览 0提问于2020-01-03得票数 0
假设您在其他地方存储了一个文档in数组(例如，在Redis排序集中)。
使用{ _id: { $in: ids }}查询Mongo文档和按照与ids数组相同的顺序排序结果的最有效方法是什么？
示例
var ids = [3,2,1,6,7];
db.records.find({ _id: { $in: ids }})
.sort({
// ???
});
// expecting [{_id: 3}, {_id: 2}, {_id: 1}, {_id: 6}, {_id: 7}]
我知道我可以在应用程序中进行排序，但我想知道，在后端是否可以更高效地进行排序。
浏览 4提问于2013-12-04得票数 17
回答已采纳
我正在创建一个mongo聚合查询，它在我的$subtract块中使用了一个$match操作符。如以下代码所述。
这个查询不工作：
db.coll.aggregate(
[
{
$match: {
timestamp: {
$gte: {
$subtract: [new Date(), 24 * 60 * 60 * 1000]
}
}
}
},
{
$group: {
浏览 6提问于2015-03-09得票数 6
回答已采纳
我在服务器中使用MongoDB，并使用多维数据集js& mongosqld开发BI工具，该工具在mongo在本地运行时工作，但是在使用M0层迁移到Atlas之后，我无法再使用mongosqld连接到它，这是我得到的错误：
无法加载MongoDB信息:未能为加载服务器集群信息创建管理会话:无法执行命令:服务器选择错误:服务器选择超时
再次检查文档，我意识到在M0中不支持BI连接器：
https://docs.atlas.mongodb.com/bi-connection/#bi-connection
所以我猜这个错误是预期的？
在这种情况下，在继续使用M0层的同时开发可视化工具还有哪些其
浏览 0提问于2019-12-11得票数 0
我有一个mongo聚合组查询：
db.wizard.aggregate(
{
$group: {
_id: "$title",
versions: { $push: {version:"$version", author:"$author", dateAdded:"$dateAdded"}}
}
})
我需要Java Spring-Data-MongoDB中的这个查询，我当前的解决方案如下所示：
Aggregation agg = Aggregation.newAggregation(
浏览 3提问于2016-09-08得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
