O que você basicamente quer é um agrupamento duplo, mas você não obtém todo o objeto de data de volta usando o operadores de agregação de data , apenas as partes relevantes:
db.collection.aggregate([
{ "$group": {
"_id": {
"customerId": "$customerId",
"day": { "$dayOfYear": "$startTime" },
"hour": { "$hour": "$startTime" }
},
"pings": { "$sum": "$ping" },
"links": { "$sum": "$link" }
}},
{ "$group": {
"_id": {
"customerId": "$_id.customerId",
"day": "$_id.day"
},
"hours": {
"$push": {
"hour": "$_id.hour",
"pings": "$pings",
"links": "$links"
}
}
}}
])
O duplo
$group
fornece o formato desejado, colocando os resultados em uma matriz por dia. Documento único na amostra, mas você basicamente obtém resultados como este:{
"_id" : {
"customerId" : 123,
"day" : 365
},
"hours" : [
{
"hour" : 10,
"pings" : 2,
"links" : 3
}
]
}
Se você achar os resultados dos operadores de data difíceis de lidar ou quiser um resultado de "passagem" simplificado para objetos de data, poderá converter como carimbos de data e hora de época:
db.collection.aggregate([
{ "$group": {
"_id": {
"customerId": "$customerId",
"day": {
"$subtract": [
{ "$subtract": [ "$startTime", new Date("1970-01-01") ] },
{
"$mod": [
{ "$subtract": [ "$startTime", new Date("1970-01-01") ] },
1000*60*60*24
]
}
]
},
"hour": {
"$subtract": [
{ "$subtract": [ "$startTime", new Date("1970-01-01") ] },
{
"$mod": [
{ "$subtract": [ "$startTime", new Date("1970-01-01") ] },
1000*60*60
]
}
]
}
},
"pings": { "$sum": "$ping" },
"links": { "$sum": "$link" }
}},
{ "$group": {
"_id": {
"customerId": "$_id.customerId",
"day": "$_id.day"
},
"hours": {
"$push": {
"hour": "$_id.hour",
"pings": "$pings",
"links": "$links"
}
}
}}
])
O truque é quando você
$subtract
um objeto de data de outro, você obtém o valor "época" de volta como resultado. Nesse caso, usamos a data de início "epoch" para obter todo o valor do carimbo de data e hora e apenas fornecemos a "data matemática" para corrigir os horários para os intervalos necessários. Então o resultado:{
"_id" : {
"customerId" : 123,
"day" : NumberLong("1419984000000")
},
"hours" : [
{
"hour" : NumberLong("1420020000000"),
"pings" : 2,
"links" : 3
}
]
}
O que pode ser mais palatável para você do que o que os operadores de data fornecem como resultado, dependendo de suas necessidades.
Você também pode adicionar um pequeno atalho para isso com o MongoDB 2.6 através do
$let
operador que permite declarar "variáveis" para operações com escopo:db.event.aggregate([
{ "$group": {
"_id": {
"$let": {
"vars": {
"date": { "$subtract": [ "$startTime", new Date("1970-01-01") ] },
"day": 1000*60*60*24,
"hour": 1000*60*60
},
"in": {
"customerId": "$customerId",
"day": {
"$subtract": [
"$$date",
{ "$mod": [ "$$date", "$$day" ] }
]
},
"hour": {
"$subtract": [
"$$date",
{ "$mod": [ "$$date", "$$hour" ] }
]
}
}
}
},
"pings": { "$sum": "$ping" },
"links": { "$sum": "$link" }
}},
{ "$group": {
"_id": {
"customerId": "$_id.customerId",
"day": "$_id.day"
},
"hours": {
"$push": {
"hour": "$_id.hour",
"pings": "$pings",
"links": "$links"
}
}
}}
])
Também quase esqueci de mencionar que seus valores para "ping" e "link" são na verdade strings, a menos que seja um erro de digitação. Mas se não, certifique-se de convertê-los como números primeiro.
