Jak znormalizować/zredukować dane czasowe w mongoDB?

Oto jak możesz to zrobić w ramach agregacji. Używam małego uproszczenia - grupuję tylko rok, miesiąc i datę - w twoim przypadku będziesz musiał dodać godzinę i minutę dla dokładniejszych obliczeń. Masz również wybór, czy wykonać średnią ważoną, jeśli rozkład punktów w otrzymanej próbce danych nie jest jednolity.

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

Uruchomiłem to z losowymi przykładowymi danymi i otrzymałem coś w tym formacie:

[
    {
        "_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 widać, jest to jeden wynik na kombinację array_serial, nazwy portu, roku/miesiąca/daty. Możesz użyć $sort, aby ustawić je w kolejności, w jakiej chcesz je stamtąd przetworzyć.

Oto, w jaki sposób można rozszerzyć etap projektu o godzinę i minutę, zaokrąglając minuty do średniej co pięć 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
    }
}

Mam nadzieję, że będziesz w stanie rozszerzyć to na swoje konkretne dane i wymagania.