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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/**
* Tests correctness of time-series bucket granularity configuration.
*
* @tags: [
* # TODO SERVER-57570: Remove this tag.
* assumes_against_mongod_not_mongos,
* assumes_no_implicit_collection_creation_after_drop,
* assumes_unsharded_collection,
* # 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,
* does_not_support_transactions,
* requires_timeseries,
* # Same goes for tenant migrations.
* tenant_migration_incompatible,
* ]
*/
(function() {
(function testSeconds() {
let coll = db.bucket_timestamp_rounding_granularitySeconds;
coll.drop();
assert.commandWorked(db.createCollection(
coll.getName(), {timeseries: {timeField: 't', granularity: 'seconds'}}));
// Ensure min time is rounded down to nearest minute.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open a new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:05.000Z")}));
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
const buckets = bucketsColl.find().toArray();
assert.eq(1, buckets.length);
assert.eq(buckets[0].control.min.t, ISODate("2021-04-22T20:10:00.000Z"));
})();
(function testMinutes() {
let coll = db.bucket_timestamp_rounding_granularityMinutes;
coll.drop();
assert.commandWorked(db.createCollection(
coll.getName(), {timeseries: {timeField: 't', granularity: 'minutes'}}));
// Ensure min time is rounded down to nearest hour.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open a new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:05:00.000Z")}));
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
const buckets = bucketsColl.find().toArray();
assert.eq(1, buckets.length);
assert.eq(buckets[0].control.min.t, ISODate("2021-04-22T20:00:00.000Z"));
})();
(function testHours() {
let coll = db.bucket_timestamp_rounding_granularityHours;
coll.drop();
assert.commandWorked(
db.createCollection(coll.getName(), {timeseries: {timeField: 't', granularity: 'hours'}}));
// Ensure min time is rounded down to nearest day.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open a new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T10:00:00.000Z")}));
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
const buckets = bucketsColl.find().toArray();
assert.eq(1, buckets.length);
assert.eq(buckets[0].control.min.t, ISODate("2021-04-22T00:00:00.000Z"));
})();
(function testSecondsToMinutes() {
let coll = db.bucket_timestamp_rounding_granularitySecondsToMinutes;
coll.drop();
assert.commandWorked(db.createCollection(
coll.getName(), {timeseries: {timeField: 't', granularity: 'seconds'}}));
// Ensure min time is rounded down to nearest minute.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open a new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:05.000Z")}));
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
let buckets = bucketsColl.find().toArray();
assert.eq(1, buckets.length);
assert.eq(buckets[0].control.min.t, ISODate("2021-04-22T20:10:00.000Z"));
// Now let's bump to minutes and make sure we get the expected behavior
assert.commandWorked(
db.runCommand({collMod: coll.getName(), timeseries: {granularity: 'minutes'}}));
// Open a new bucket and ensure min time is rounded down to nearest hour.
assert.commandWorked(coll.insert({t: ISODate("2021-04-24T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open another new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-24T20:05:00.000Z")}));
buckets = bucketsColl.find().toArray();
assert.eq(2, buckets.length);
assert.eq(buckets[1].control.min.t, ISODate("2021-04-24T20:00:00.000Z"));
})();
(function testMinutesToHours() {
let coll = db.bucket_timestamp_rounding_granularityMinutesToHours;
coll.drop();
assert.commandWorked(db.createCollection(
coll.getName(), {timeseries: {timeField: 't', granularity: 'minutes'}}));
// Ensure min time is rounded down to nearest hour.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open a new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-04-22T20:05:00.000Z")}));
let bucketsColl = db.getCollection('system.buckets.' + coll.getName());
let buckets = bucketsColl.find().toArray();
assert.eq(1, buckets.length);
assert.eq(buckets[0].control.min.t, ISODate("2021-04-22T20:00:00.000Z"));
// Now let's bump to minutes and make sure we get the expected behavior
assert.commandWorked(
db.runCommand({collMod: coll.getName(), timeseries: {granularity: 'hours'}}));
// Open a new bucket and ensure min time is rounded down to nearest day.
assert.commandWorked(coll.insert({t: ISODate("2021-06-24T20:10:14.134Z")}));
// And that going backwards, but after the rounding point, doesn't open another new bucket.
assert.commandWorked(coll.insert({t: ISODate("2021-06-24T10:00:00.000Z")}));
buckets = bucketsColl.find().toArray();
assert.eq(2, buckets.length);
assert.eq(buckets[1].control.min.t, ISODate("2021-06-24T00:00:00.000Z"));
})();
})();
|
