Есть ли способ группировки результатов из нескольких документов при выполнении агрегации - PullRequest
Новая
       1

Есть ли способ группировки результатов из нескольких документов при выполнении агрегации

2 голосов
/ 29 марта 2019

Я новичок в Монго и пытаюсь выполнить агрегационный запрос для расчета минимальных и максимальных временных отметок для данного документа.

Образцы документов ниже - 

{
"_id" : ObjectId("5c9cd93adddca9ebb2b3fcba"),
"frequency" : 5,
"s_id" : "30081993",
"timestamp" : NumberLong(1546300800000),
"date" : ISODate("2019-01-01T00:00:00.000Z"),

"values" : {
    "1547439900000" : {
        "number_of_values" : 3,
        "min_value" : 32.13,
        "max_value" : 81.42
    },
    "1547440200000" : {
        "number_of_values" : 3,
        "min_value" : 48.08,
        "max_value" : 84.52
    },
    "1547440500000" : {
        "number_of_values" : 2,
        "min_value" : 27.39,
        "max_value" : 94.64
    }
  }
}

{
"_id" : ObjectId("5c9cd851dddca9ebb2b3f2ac"),
"frequency" : 5,
"s_id" : "27061995",
"timestamp" : NumberLong(1546300800000),
"date" : ISODate("2019-01-01T00:00:00.000Z"),

"values" : {
    "1547539900000" : {
        "number_of_values" : 31,
        "min_value" : 322.13,
        "max_value" : 831.42
    },
    "1547540200000" : {
        "number_of_values" : 3,
        "min_value" : 418.08,
        "max_value" : 8114.52
    },
    "1547740500000" : {
        "number_of_values" : 2,
        "min_value" : 207.39,
        "max_value" : 940.64
    }
  }
}

Я предложил следующий запрос, который работает для одного документа. 

    db.testdb.aggregate([
      {
        $match: {
          "s_id": "30081993",
          "frequency": 5,

        }
      },
      {
        $project: {
          _id: 1,
          valuesarray: {
            $objectToArray: "$values"
          }
        }
      },
      {
        $unwind: "$valuesarray"
      },
      {
        $group: {
          "_id": "",
          "min_timestamp": {
            $min: "$valuesarray.k"
          },
          "max_timestamp": {
            $max: "$valuesarray.k"
          }
        }
      }
    ]);

Выход ниже 

{
    "_id" : "",
    "min_timestamp" : "1547439900000",
    "max_timestamp" : "1547440500000"
}

Я хочу запрос агрегации, который может вычислить макс / мин меток времени, но для нескольких документов, т.е. я хочу использовать оператор $ in во время этапа $ match и получить min / max всех s_id. Это возможно?

Ожидается: 

{
    "_id" : "30081993",
    "min_timestamp" : "1547439900000",
    "max_timestamp" : "1547440500000"
}


{
    "_id" : "27061995",
    "min_timestamp" : "1547539900000",
    "max_timestamp" : "1547740500000"
}

1 Ответ

1 голос
/ 30 марта 2019

Да, для работы с несколькими документами требуются только небольшие изменения.

На этапе $match укажите запрос $in: 

$match: {
    "s_id": { $in : [ "30081993", "27061995" ] }, 
    "frequency": 5,
}

На этапе $project переименуйте s_id в _id, чтобы сохранить s_id, связанный с каждым документом: 

$project: {
    _id: "$s_id",
    valuesarray: {
        $objectToArray: "$values"
    }
}

На этапе $group сгруппируйте по _id (первоначально s_id), чтобы убедиться, что мы правильно сгруппировали временные метки вместе перед вычислением $min / $max: 

$group: {
    "_id": "$_id",
    "min_timestamp": {
        $min: "$valuesarray.k"
    },
    "max_timestamp": {
        $max: "$valuesarray.k"
    }
}

Весь трубопровод: 

db.testdb.aggregate([
  {
    $match: {
      "s_id": { $in : [ "30081993", "27061995" ] }, 
      "frequency": 5,
    }
  },
  {
    $project: {
      _id: "$s_id",
      valuesarray: {
        $objectToArray: "$values"
      }
    }
  },
  {
    $unwind: "$valuesarray"
  },
  {
    $group: {
      "_id": "$_id",
      "min_timestamp": {
        $min: "$valuesarray.k"
      },
      "max_timestamp": {
        $max: "$valuesarray.k"
      }
    }
  }
]);
...