Как искать документы MongoDB на разных уровнях вложенности?

В настоящее время я анализирую system.profile-коллекцию базы данных MongoDB. Я хотел бы найти запросы, в которых есть стадия с COLLSCAN или IXSCAN. Моя проблема в том, что поле stage может встречаться на нескольких уровнях (...: сокращенный JSON):

{
    "op" : "query",
    "ns" : "spt.coll",
    "query" : {
        "user" : "userC"
    },
    "ntoreturn" : 1,
    ...
    "millis" : 0,
    "execStats" : {
        "stage" : "PROJECTION",
        "nReturned" : 1,
        ...
        "transformBy" : {
            "settings.arr" : 1
        },
        "inputStage" : {
            "stage" : "FETCH",
            "nReturned" : 1,
            ...
            "alreadyHasObj" : 0,
            "inputStage" : {
                "stage" : "IXSCAN",
                "nReturned" : 1,
                ...
                "matchTested" : 0
            }
        }
    },
    "ts" : ISODate("2015-07-30T09:16:22.551Z"),
    "client" : "127.0.0.1",
    "allUsers" : [ ],
    "user" : ""
}

В приведенном выше примере этап происходит на 3 уровнях:

  1. "execStats.stage"
  2. "execStats.inputStage.stage"
  3. "execStats.inputStage.inputStage.stage"

Могут быть еще более глубокие вложенные этапы. Есть ли способ вернуть все документы, которые имеют stage: "IXSCAN" или stage: "COLLSCAN" на любом из этих уровней вложенности? или мне нужно выполнить запрос для каждого уровня вложенности?

Я попытался использовать следующую функцию, ссылаясь на Как найти имя поля MongoDB на произвольной глубине , но, к сожалению, это дает ошибку:

db.system.profile.find(
  function () {
    var findKey = "stage",
        findVal = "COLLSCAN";

    function inspectObj(doc) {
      return Object.keys(doc).some(function(key) {
        if ( typeof(doc[key]) == "object" ) {
          return inspectObj(doc[key]);
        } else {
          return ( key == findKey && doc[key] == findVal );
        }
      });
    }
    return inspectObj(this);
  }
)

Сообщение об ошибке:

Error: error: {
    "$err" : "TypeError: Object.keys called on non-object\n    at Function.keys (native)\n    at inspectObj (_funcs1:6:25)\n    at _funcs1:8:22\n    at Array.some (native)\n    at inspectObj (_funcs1:6:35)\n    at _funcs1:8:22\n    at Array.some (native)\n    at inspectObj (_funcs1:6:35)\n    at _funcs1 (_funcs1:14:16) near 'rn Object.keys(doc).some(function(key) '  (line 6)",
    "code" : 16722
}

Чтобы воспроизвести приведенный выше JSON, используйте следующий код:

use spt

db.coll.drop()

db.coll.insert([
  {settings: {arr: ["a", "b"]}, user: "userA"},
  {settings: {arr: ["c", "d"]}, user: "userB"},
  {settings: {arr: ["e", "f"]}, user: "userC"},
  {settings: {arr: ["g", "g"]}, user: "userD"},
])

db.coll.ensureIndex({user: 1})

db.setProfilingLevel(0)
db.system.profile.drop()
db.setProfilingLevel(2)


db.coll.find({user: "userC"}, {"settings.arr": 1}).limit(1).pretty()
db.system.profile.find().pretty()

person Edward    schedule 30.07.2015    source источник


Ответы (1)


Упомянутая вами ошибка возникает из-за Object.keys, когда объект не является перечисляемым. Простой способ — поймать и проигнорировать ошибку:

db.system.profile.find(
  // Returns all documents, for which this function returns true.
  function () {
    var findKey = "stage",
        findVal = "COLLSCAN";

    function inspectObj(doc) {
      // Object.keys(doc) works only for enumerables like (Arrays and Documents)
      // https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Object/keys
      // The incoming Object might also be e.g. `ISODate("2015-07-29T08:20:42.768Z")`
      // Thus you need to catch (and ignore) TypeErrors thrown by Object.keys()
      var contains = false;
      try {
            contains = Object.keys(doc).some(function(key) {
              cVal = doc[key];
              if ( typeof(cVal) == "object" ) {
                // Recursive call if value is an Object.
                return inspectObj(doc[key]);
              } else {
                return ( key == findKey && doc[key] == findVal );
              }
            });
      } catch(TypeError) {
        // ignore TypeError
      }
      return contains;
    }

    return inspectObj(this);
  }, {op: 1, ns:1, query: 1}
)
person R_User    schedule 02.08.2015