1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
/**
* This test confirms that telemetry store key fields are properly nested and none are missing.
* @tags: [featureFlagTelemetry]
*/
load("jstests/libs/telemetry_utils.js");
(function() {
"use strict";
function confirmAllFieldsPresent(queryStatsEntries) {
const kApplicationName = "MongoDB Shell";
const queryShapeFindFields = [
"cmdNs",
"command",
"filter",
"sort",
"projection",
"hint",
"skip",
"limit",
"singleBatch",
"max",
"min",
"returnKey",
"showRecordId",
"tailable",
"oplogReplay",
"awaitData",
"collation",
"allowDiskUse",
"let"
];
// The outer fields not nested inside queryShape.
const queryStatsKeyFields = [
"queryShape",
"batchSize",
"comment",
"maxTimeMS",
"noCursorTimeout",
"readConcern",
"allowPartialResults",
"applicationName"
];
for (const entry of queryStatsEntries) {
let fieldCounter = 0;
assert.eq(entry.key.queryShape.command, "find");
assert.eq(entry.key.applicationName, kApplicationName);
for (const field in entry.key.queryShape) {
assert(queryShapeFindFields.includes(field));
fieldCounter++;
}
assert.eq(fieldCounter, queryShapeFindFields.length);
fieldCounter = 0;
for (const field in entry.key) {
assert(queryStatsKeyFields.includes(field));
fieldCounter++;
}
assert.eq(fieldCounter, queryStatsKeyFields.length);
}
}
// Turn on the collecting of telemetry metrics.
let options = {
setParameter: {internalQueryStatsSamplingRate: -1},
};
const conn = MongoRunner.runMongod(options);
const testDB = conn.getDB('test');
var coll = testDB[jsTestName()];
coll.drop();
// Have to create an index for hint not to fail.
assert.commandWorked(coll.createIndex({v: 1}));
let commandObj = {
find: coll.getName(),
filter: {v: {$eq: 2}},
oplogReplay: true,
comment: "this is a test!!",
min: {"v": 0},
max: {"v": 4},
hint: {"v": 1},
sort: {a: -1},
returnKey: false,
noCursorTimeout: true,
showRecordId: false,
tailable: false,
awaitData: false,
allowPartialResults: true,
skip: 1,
limit: 2,
maxTimeMS: 500,
collation: {locale: "en_US", strength: 2},
allowDiskUse: true,
readConcern: {level: "local"},
batchSize: 2,
singleBatch: true,
let : {},
projection: {_id: 0},
};
assert.commandWorked(testDB.runCommand(commandObj));
let telemetry = getTelemetry(conn);
assert.eq(1, telemetry.length);
confirmAllFieldsPresent(telemetry);
MongoRunner.stopMongod(conn);
}());
|
