Монго БД Агрегационный конвейер - PullRequest
0 голосов
/ 03 ноября 2018

Я новичок в DB Mango, может кто-нибудь объяснить, как получить приведенную ниже статистику из этого в результате одного запроса

  • Сгруппировать по "lastActionTimestamp"
  • Мы должны получить общее количество «extractFinished», «formationFinished »,« loadFinished », сбой и статус = дубликаты документов. Кто-нибудь может помочь с этим?

Пример набора данных:

   "migration" : {
            "sourceSystem" : "Test",
            "targetSystem" : "Test2",
            "lastAction" : "load finished",
            "lastActionTimestamp" : ISODate("2018-04-28T19:08:00.335Z"),
            "extractionStarted" : ISODate("2018-04-14T02:22:46.882Z"),
            "extractionFinished" : ISODate("2018-04-14T02:22:46.882Z"),
            "failed" : false
            "status" : "Valid",
            "deltaStatus" : false,
            "transformationStarted" : ISODate("2018-04-22T14:33:46.020Z"),
            "transformationFinished" : ISODate("2018-04-22T14:33:46.023Z"),
            "loadStarted" : ISODate("2018-04-28T19:07:58.803Z"),
            "loadFinished" : ISODate("2018-04-28T19:08:00.336Z"),
            "failureReason" : ""
        }

        "migration" : {
            "sourceSystem" : "Test",
            "targetSystem" : "Test2",
            "lastAction" : "load finished",
            "lastActionTimestamp" : ISODate("2018-04-28T19:08:00.335Z"),
            "extractionStarted" : ISODate("2018-04-14T02:22:46.882Z"),
            "extractionFinished" : ISODate("2018-04-14T02:22:46.882Z"),
            "failed" : true
            "status" : "Valid",
            "deltaStatus" : false,
            "transformationStarted" : ISODate("2018-04-22T14:33:46.020Z"),
            "transformationFinished" : ISODate("2018-04-22T14:33:46.023Z"),

            "failureReason" : "Some Issue"
        }
        "migration" : {
            "sourceSystem" : "Test",
            "targetSystem" : "Test2",
            "lastAction" : "load finished",
            "lastActionTimestamp" : ISODate("2018-04-28T19:08:00.335Z"),
            "extractionStarted" : ISODate("2018-04-14T02:22:46.882Z"),
            "extractionFinished" : ISODate("2018-04-14T02:22:46.882Z"),
            "failed" : False
            "status" : "Duplicate",
            "deltaStatus" : false,
            "transformationStarted" : ISODate("2018-04-22T14:33:46.020Z"),
            "transformationFinished" : ISODate("2018-04-22T14:33:46.023Z"),

            "failureReason" : ""
        }

Ожидаемый результат:

Добыча завершена: 3 Преобразование завершено: 3 Загрузка завершена: 1 Дубликат: 1 Ошибка: 1

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