MongoDB получает данные через определенные промежутки времени

Question

У меня есть данные в MongoDb в следующем формате:

/* 1 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbaf"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:11.000Z"),
    "WIZ_VAR_10" : 710.0,
    "WIZ_VAR_11" : 910.0,
    "WIZ_VAR_12" : 910.0,
    "TIMESTAMP_EP" : 1483854251.0
}

/* 2 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb0"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:12.000Z"),
    "WIZ_VAR_10" : 720.0,
    "WIZ_VAR_11" : 920.0,
    "WIZ_VAR_12" : 920.0,
    "TIMESTAMP_EP" : 1483854252.0
}

/* 3 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb1"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:13.000Z"),
    "WIZ_VAR_10" : 730.0,
    "WIZ_VAR_11" : 930.0,
    "WIZ_VAR_12" : 930.0,
    "TIMESTAMP_EP" : 1483854253.0
}

/* 4 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb2"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:14.000Z"),
    "WIZ_VAR_10" : 740.0,
    "WIZ_VAR_11" : 940.0,
    "WIZ_VAR_12" : 940.0,
    "TIMESTAMP_EP" : 1483854254.0
}

/* 5 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb3"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:15.000Z"),
    "WIZ_VAR_10" : 750.0,
    "WIZ_VAR_11" : 950.0,
    "WIZ_VAR_12" : 950.0,
    "TIMESTAMP_EP" : 1483854255.0
}

/* 6 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb4"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:16.000Z"),
    "WIZ_VAR_10" : 760.0,
    "WIZ_VAR_11" : 960.0,
    "WIZ_VAR_12" : 960.0,
    "TIMESTAMP_EP" : 1483854256.0
}

/* 7 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb5"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:17.000Z"),
    "WIZ_VAR_10" : 770.0,
    "WIZ_VAR_11" : 970.0,
    "WIZ_VAR_12" : 970.0,
    "TIMESTAMP_EP" : 1483854257.0
}

/* 8 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb6"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:18.000Z"),
    "WIZ_VAR_10" : 780.0,
    "WIZ_VAR_11" : 980.0,
    "WIZ_VAR_12" : 980.0,
    "TIMESTAMP_EP" : 1483854258.0
}

/* 9 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb7"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:19.000Z"),
    "WIZ_VAR_10" : 790.0,
    "WIZ_VAR_11" : 990.0,
    "WIZ_VAR_12" : 990.0,
    "TIMESTAMP_EP" : 1483854259.0
}

/* 10 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb8"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:20.000Z"),
    "WIZ_VAR_10" : 800.0,
    "WIZ_VAR_11" : 0.0,
    "WIZ_VAR_12" : 0.0,
    "TIMESTAMP_EP" : 1483854260.0
}

/* 11 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb9"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:21.000Z"),
    "WIZ_VAR_10" : 810.0,
    "WIZ_VAR_11" : 10.0,
    "WIZ_VAR_12" : 10.0,
    "TIMESTAMP_EP" : 1483854261.0
}

/* 12 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbba"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:22.000Z"),
    "WIZ_VAR_10" : 820.0,
    "WIZ_VAR_11" : 20.0,
    "WIZ_VAR_12" : 20.0,
    "TIMESTAMP_EP" : 1483854262.0
}

Чего я хотел бы добиться, так это получать записи с интервалом в 5 секунд. Поэтому ожидаемый результат должен быть

/* 1 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbaf"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:11.000Z"),
    "WIZ_VAR_10" : 710.0,
    "WIZ_VAR_11" : 910.0,
    "WIZ_VAR_12" : 910.0,
    "TIMESTAMP_EP" : 1483854251.0
}
/* 6 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb4"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:16.000Z"),
    "WIZ_VAR_10" : 760.0,
    "WIZ_VAR_11" : 960.0,
    "WIZ_VAR_12" : 960.0,
    "TIMESTAMP_EP" : 1483854256.0
}
/* 11 */
{
    "_id" : ObjectId("5a40f49743bf8220c865cbb9"),
    "TIMESTAMP" : ISODate("2017-01-08T11:14:21.000Z"),
    "WIZ_VAR_10" : 810.0,
    "WIZ_VAR_11" : 10.0,
    "WIZ_VAR_12" : 10.0,
    "TIMESTAMP_EP" : 1483854261.0
}

Так что, по сути, я хочу получать записи с интервалом. Я проверил структуру агрегации, но не смог найти точное решение для того же. Любая помощь высоко ценится.

Answer 1

Вы можете использовать оператор $ second , который занимает часть секунд от даты (0-60), а затем $ mod для получения по модулю 5 (интервал 5 секунд). В вашем случае вы хотите начать с 11, поэтому вам следует проверить, является ли модуль по модулю $ eq до 1. Чтобы использовать эти операторы непосредственно в $match, вам нужен $ expr , который доступен в MongoDB v 3.6:

db.col.aggregate([
    {
        $match: {
            $expr: {
                $eq: [ { $mod: [ { $second: "$TIMESTAMP" }, 5 ] }, 1 ]
            }            
        }
    }
])

Если вы используете более низкую версию MongoDB, вы можете попробовать с $ redact :

db.col.aggregate([
    {
        $redact: {
            $cond: {
                if: { $eq: [ { $mod: [ { $second: "$TIMESTAMP" }, 5 ] }, 1 ] },
                then: "$$KEEP",
                else: "$$PRUNE"
            }            
        }
    }
])