sql >> Databáze >  >> NoSQL >> MongoDB

Jak normalizovat/snížit časová data v mongoDB?

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.



  1. Vložte nebo aktualizujte mnoho dokumentů v MongoDB

  2. Podporuje MongoDB typy s plovoucí desetinnou čárkou?

  3. Rozdíl mezi zdobením vlastnosti v C# pomocí BsonRepresentation(BsonType.ObjectId) vs BsonId vs ObjectId

  4. MongoDB $mul