Пн go агрегат - расчет по датам - PullRequest
0 голосов
/ 26 февраля 2020

Вот пример документа.

{"_id":{"$oid":"5e557779ed588826d84cef11"},
"meter_id":"1001",
"date":{"$date":{"$numberLong":"1509474600000"}},
"parameter_name":"hvac","voltage":{"unit":"V"},
"current":{"unit":"AMP"},
"powerFactor":{"unit":"phi"},
"angle":{"unit":"degree"},
"activePower":{"unit":"kwh"},
"reactivePower":{"unit":"kwh"},
"apparentPower":{"unit":"kwh"},
"frequency":{"unit":"hz"},
"thd":{"unit":"percentage"},
"energy":{"Energy":"5.7"},
"power":{"unit":"watt"},

И около 100 000 документов. Я хочу отфильтровать документы, дата которых больше указанной мной даты, и рассчитать общую энергию, т. Е. Энергию. Энергия

Я использовал приведенную ниже агрегацию, но, похоже, она не работает

const endDate = new Date(12-12-2018)
 MeterData.aggregate([
      {
          $group: {
              _id: "$meter_id",
              total: { $sum: 1 },
              totalEnergy: { $sum: { $toDouble: "$energy.Energy"
                   } },
                   dateSum: {
                    $sum: {
                      $toDouble: {
                        $not: [{
                          $cond: {
                            if: {
                              $gte: [
                                "$date", endDate
                              ]
                            },
                            then: "$energy.Energy",
                            else: 0
                          }
                        }

                        ]


                    }
                    }
                   }
          }
      }
  ])

1 Ответ

1 голос
/ 26 февраля 2020

Было бы это:

db.collection.aggregate([
   { $match: { date: { $gte: ISODate("2016-12-12") } } },
   {
      $group: {
         _id: "$meter_id",
         total: { $sum: 1 },
         totalEnergy: { $sum: "$energy.Energy" }
      }
   }
])

См. Пн go Детская площадка

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...