È un po' possibile. Tieni presente che Pandas è una libreria creata esplicitamente per questo tipo di attività e una bestia, mentre MongoDB è pensato per essere un database. Ma è molto probabile che quanto segue soddisfi le tue esigenze, se si ignora la tua probabile necessità di utilizzare l'interpolazione:
Supponendo che tu abbia i seguenti dati archiviati in una raccolta MongoDB denominata devices
/* 0 */
{
"_id" : ObjectId("543fc08ccf1e8c06c0288802"),
"t" : ISODate("2014-10-20T14:56:44.097+02:00"),
"a" : "192.168.0.16",
"i" : 0,
"o" : 32
}
/* 1 */
{
"_id" : ObjectId("543fc08ccf1e8c06c0288803"),
"t" : ISODate("2014-10-20T14:56:59.107+02:00"),
"a" : "192.168.0.16",
"i" : 14243,
"o" : 8430
}
and so on...
che, in questo caso, viene campionato ogni 15 secondi circa, ma potrebbe anche essere irregolare. Se vuoi ricampionarlo fino a un limite di 5 minuti per un determinato giorno, dovresti procedere come segue:
var low = ISODate("2014-10-23T00:00:00.000+02:00")
var high = ISODate("2014-10-24T00:00:00.000+02:00")
var interval = 5*60*1000;
db.devices.aggregate([
{$match: {t:{$gte: low, $lt: high}, a:"192.168.0.16"}},
{$group: {
_id:{
$subtract: ["$t", {
$mod: [{
$subtract: ["$t", low]
}, interval]
}]
},
total: {$sum: 1},
incoming: {$sum: "$i"},
outgoing: {$sum: "$o"},
}
},
{
$project: {
total: true,
incoming: true,
outgoing: true,
incoming_avg: {$divide: ["$incoming", "$total"]},
outgoing_avg: {$divide: ["$outgoing", "$total"]},
},
},
{$sort: {_id : 1}}
])
Ciò risulterà in qualcosa del genere
{
"result" : [
{
"_id" : ISODate("2014-10-23T07:25:00.000+02:00"),
"total" : 8,
"incoming" : 11039108,
"outgoing" : 404983,
"incoming_avg" : 1379888.5,
"outgoing_avg" : 50622.875
},
{
"_id" : ISODate("2014-10-23T07:30:00.000+02:00"),
"total" : 19,
"incoming" : 187241,
"outgoing" : 239912,
"incoming_avg" : 9854.78947368421,
"outgoing_avg" : 12626.94736842105
},
{
"_id" : ISODate("2014-10-23T07:35:00.000+02:00"),
"total" : 17,
"incoming" : 22420099,
"outgoing" : 1018766,
"incoming_avg" : 1318829.352941176,
"outgoing_avg" : 59927.41176470588
},
...
Se vuoi scartare il totale in entrata, lascia la riga fuori nella fase $project. Incoming_average è solo un esempio di come calcolare la media, nel caso in cui i dati archiviati siano qualcosa di simile a ciò che rrdtool chiama un indicatore (temperatura, cpu, dati del sensore). Se stai solo dopo la somma aggregata in quell'intervallo di tempo, che è il campo in entrata e in uscita, puoi lasciare fuori l'intero $project stage. Serve solo per calcolare la media dell'intervallo di tempo.
Vedi aggregazione Mongo di ISODate in blocchi di 45 minuti
