Mongodb聚合5分钟
Mongodb聚合5分钟
提问于 2019-12-24 15:24:03
我有IoT传感器，它每秒钟发送一次事件，并以MongoDB格式存储事件如下：
{
"_id" : "stp_23",
"HP" : [
1261.0,
1357.0,
1337.0,
1250.0,
1269.0,
1134.0,
1219.0,
1269.0,
1166.0,
1361.0,
1246.0,
... ]
"TS" : [
"2019-12-20T00:00:04.6440124Z",
"2019-12-20T00:00:14.6440124Z",
"2019-12-20T00:00:24.6440124Z",
"2019-12-20T00:00:34.6450042Z",
"2019-12-20T00:00:44.6450042Z",
"2019-12-20T00:00:54.6450042Z",
"2019-12-20T00:01:55.6460113Z",
"2019-12-20T00:02:05.6460113Z",
"2019-12-20T00:02:15.6460113Z",
"2019-12-20T00:02:35.6460113Z"
... ]
"_id" : "stp_24" : ....
}我需要根据TS值每5分钟创建一个聚合。我按照下面的查询执行，因为TS是时间戳获取错误的数组。
在没有$convert值的onError中不支持从数组到日期的转换
db.hp_daily.aggregate([
{ "$group": {
"_id": {
"$toDate": {
"$subtract": [
{ "$toLong": { "$toDate": "$TS" } },
{ "$mod": [ { "$toLong": { "$toDate": "$TS" } }, 1000 * 60 * 5 ] }
]
}
},
"count": { "$sum": 1 }
}}
])我在寻找这样的结果：
[
{
"_id" : "stp_23",
"ts" : ISODate("2019-12-20T00:05:00.000Z"),
"avgHP" : 1200
},
{
"_id" : "stp_24",
"ts" : ISODate("2019-12-20T00:10:00.000Z"),
"avgHP" : 1350
}
]回答 1
Stack Overflow用户
发布于 2019-12-25 12:44:46
假设
- 您的
HP和TS具有相同的数组大小，每个时间戳对应HP值。 - 修改最后3个时间戳(目前的例子)，以获得不同的时间范围
设置
- 我们需要将数组转换为单个对象来应用
$toDate。 - 此外，我们还需要将每个HP值链接为对应的
TS值链接。 - 然后，我们应用您的聚合(稍微改变了一点)并获得所需的结果。
db.hp_daily.aggregate([
{
$unwind: {
path: "$HP",
includeArrayIndex: "HP_index",
}
},
{
$unwind: {
path: "$TS",
includeArrayIndex: "TS_index",
}
},
{
$project: {
HP: 1,
TS: 1,
compare: {
$cmp: [
"$HP_index",
"$TS_index"
]
}
}
},
{
$match: {
compare: 0
}
},
{
$project: {
_id: 1,
HP: 1,
TS: 1
}
},
{
"$group": {
"_id": {
_id: "$_id",
"ts": {
"$toDate": {
"$subtract": [
{
"$toLong": {
"$toDate": "$TS"
}
},
{
"$mod": [
{
"$toLong": {
"$toDate": "$TS"
}
},
{
$multiply: [
1000,
60,
5
]
}
]
}
]
}
}
},
"avgHP": {
"$avg": "$HP"
}
}
},
{
$sort: {
"_id._id": 1,
"_id.ts": 1
}
},
{
$project: {
_id: "$_id._id",
ts: "$_id.ts",
avgHP: "$avgHP"
}
}
])[
{
"_id": "stp_23",
"avgHP": 1261,
"ts": ISODate("2019-12-20T00:00:00Z")
},
{
"_id": "stp_23",
"avgHP": 1265.3333333333333,
"ts": ISODate("2019-12-20T00:05:00Z")
}
]页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/59470788
复制相关文章
相似问题
腾讯云开发者
