Zde je návod, jak to můžete udělat v agregačním rámci. Použil jsem malé zjednodušení - seskupuji pouze podle roku, měsíce a data - ve vašem případě budete muset přidat hodinu a minutu pro jemnější výpočty. Máte také na výběr, zda chcete použít vážený průměr, pokud rozdělení bodů není v získaném vzorku dat jednotné.
project={"$project" : {
"year" : {
"$year" : "$DateTime"
},
"month" : {
"$month" : "$DateTime"
},
"day" : {
"$dayOfWeek" : "$DateTime"
},
"array_serial" : 1,
"Port Name" : 1,
"metric" : 1
}
};
group={"$group" : {
"_id" : {
"a" : "$array_serial",
"P" : "$Port Name",
"y" : "$year",
"m" : "$month",
"d" : "$day"
},
"avgMetric" : {
"$avg" : "$metric"
}
}
};
db.metrics.aggregate([project, group]).result
Spustil jsem to s několika náhodnými ukázkovými daty a získal jsem něco v tomto formátu:
[
{
"_id" : {
"a" : "12345",
"P" : "CL1-B",
"y" : 2012,
"m" : 9,
"d" : 6
},
"avgMetric" : 100.8
},
{
"_id" : {
"a" : "12345",
"P" : "CL1-B",
"y" : 2012,
"m" : 9,
"d" : 7
},
"avgMetric" : 98
},
{
"_id" : {
"a" : "12345",
"P" : "CL1-A",
"y" : 2012,
"m" : 9,
"d" : 6
},
"avgMetric" : 105
}
]
Jak vidíte, jedná se o jeden výsledek na kombinaci array_serial, název portu, rok/měsíc/datum. Pomocí $sort je můžete dostat do objednávky, ze které je chcete zpracovat.
Zde je návod, jak byste rozšířili krok projektu tak, aby zahrnoval hodinu a minutu, zatímco minuty zaokrouhlujete na průměr každých pět minut:
{
"$project" : {
"year" : {
"$year" : "$DateTime"
},
"month" : {
"$month" : "$DateTime"
},
"day" : {
"$dayOfWeek" : "$DateTime"
},
"hour" : {
"$hour" : "$DateTime"
},
"fmin" : {
"$subtract" : [
{
"$minute" : "$DateTime"
},
{
"$mod" : [
{
"$minute" : "$DateTime"
},
5
]
}
]
},
"array_serial" : 1,
"Port Name" : 1,
"metric" : 1
}
}
Doufám, že to budete moci rozšířit na vaše konkrétní data a požadavky.