В настоящее время я анализирую 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 уровнях:
"execStats.stage"
"execStats.inputStage.stage"
"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()