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
|
/**
* Tests that the space usage calculation for new fields in time-series inserts accounts for the
* control.min and control.max fields.
*
* @tags: [
* # This test depends on certain writes ending up in the same bucket. Stepdowns may result in
* # writes splitting between two primaries, and thus different buckets.
* does_not_support_stepdowns,
* # Test examines collection stats.
* requires_collstats,
* # Large measurement handling changed in binVersion 6.1.
* requires_fcv_61,
* # We need a timeseries collection.
* requires_timeseries,
* ]
*/
(function() {
"use strict";
const coll = db.getCollection(jsTestName());
const bucketColl = db.getCollection("system.buckets." + jsTestName());
const timeFieldName = "time";
const resetCollection = (() => {
coll.drop();
assert.commandWorked(
db.createCollection(jsTestName(), {timeseries: {timeField: timeFieldName}}));
});
const timeseriesBucketMaxSize = (() => {
const res =
assert.commandWorked(db.adminCommand({getParameter: 1, timeseriesBucketMaxSize: 1}));
return res.timeseriesBucketMaxSize;
})();
const checkAverageBucketSize = (() => {
const timeseriesStats = assert.commandWorked(coll.stats()).timeseries;
const averageBucketSize = timeseriesStats.numBytesUncompressed / timeseriesStats.bucketCount;
jsTestLog("Average bucket size: " + averageBucketSize);
assert.lte(averageBucketSize, timeseriesBucketMaxSize);
const firstBucket = bucketColl.find().sort({'control.min._id': 1}).toArray()[0];
assert.eq(0, firstBucket.control.min._id);
assert.eq(9, firstBucket.control.max._id);
});
// Each measurement inserted will consume roughly 1/12th of the bucket max size. In theory, we'll
// only be able to fit ten measurements per bucket. The first measurement will also create the
// control.min and control.max summaries, which will account for two measurements worth of data.
// The other measurements will not modify the control.min and control.max fields to the same degree
// as they're going to insert the same-length values. The remaining ~4% of the bucket size is left
// for other internal fields that need to be written out.
const measurementValueLength = Math.floor(timeseriesBucketMaxSize * 0.08);
const numMeasurements = 100;
jsTestLog("Testing single inserts");
resetCollection();
for (let i = 0; i < numMeasurements; i++) {
const doc = {_id: i, [timeFieldName]: ISODate(), value: "a".repeat(measurementValueLength)};
assert.commandWorked(coll.insert(doc));
}
checkAverageBucketSize();
jsTestLog("Testing batched inserts");
resetCollection();
let batch = [];
for (let i = 0; i < numMeasurements; i++) {
const doc = {_id: i, [timeFieldName]: ISODate(), value: "a".repeat(measurementValueLength)};
batch.push(doc);
}
assert.commandWorked(coll.insertMany(batch), {ordered: false});
checkAverageBucketSize();
}());
|
