在mongodb中以当地时区聚合

Roh*_*sal 8 datetime mongodb node.js mongodb-query aggregation-framework

我正在构建将在意大利使用的mongodb和nodejs中的应用程序.意大利时区是+02:00.这意味着如果任何人在7月11日凌晨01点保存一些数据,那么它将被保存为7月10日晚上11点,因为mongo以UTC格式保存日期.我们需要显示日期明智的tx计数.所以我按日期查询了.但它显示前一天的tx.这应该是什么解决方法.

> db.txs.insert({txid:"1",date : new Date("2015-07-11T01:00:00+02:00")})

> db.txs.insert({txid:"2",date : new Date("2015-07-11T05:00:00+02:00")})

> db.txs.insert({txid:"3",date : new Date("2015-07-10T21:00:00+02:00")})

> db.txs.find().pretty()

{
        "_id" : ObjectId("55a0a55499c6740f3dfe14e4"),
        "txid" : "1",
        "date" : ISODate("2015-07-10T23:00:00Z")
}
{
        "_id" : ObjectId("55a0a55599c6740f3dfe14e5"),
        "txid" : "2",
        "date" : ISODate("2015-07-11T03:00:00Z")
}
{
        "_id" : ObjectId("55a0a55699c6740f3dfe14e6"),
        "txid" : "3",
        "date" : ISODate("2015-07-10T19:00:00Z")
}

> db.txs.aggregate([
     { $group:{
         _id: { 
             day:{$dayOfMonth:"$date"}, 
             month:{$month:"$date"},
             year:{$year:"$date"} 
         },
         count:{$sum:1}
     }}
  ])

  { "_id" : { "day" : 11, "month" : 7, "year" : 2015 }, "count" : 1 }
  { "_id" : { "day" : 10, "month" : 7, "year" : 2015 }, "count" : 2 }
Run Code Online (Sandbox Code Playgroud)

它显示7月10日的2 txs和7月11日的1 txs.但我们需要在7月11日和7月10日显示1个tx.

实际上是7月11日在意大利的时候

db.txs.insert({txid:"1",date : new Date("2015-07-11T01:00:00+02:00")})
Run Code Online (Sandbox Code Playgroud)

发生但mongo存储日期为:

ISODate("2015-07-10T23:00:00Z")
Run Code Online (Sandbox Code Playgroud)

Sar*_*ana 6

在 mongo 3.6 版中添加了时区,mongo doc

用时区提取日期部分的表达式是

{ date: <dateExpression>, timezone: <tzExpression> }
Run Code Online (Sandbox Code Playgroud)

我们可以在获取日期部分时指定时区或偏移量

管道

> db.txs.aggregate([
...     { $group:{
...         _id: { 
...             day: {$dayOfMonth: {date :"$date", timezone : "Europe/Rome"}}, // timezone
...             month: {$month: {date : "$date", timezone : "+02:00"}}, //offset
...             year: {$year: {date : "$date", timezone : "+02:00"}} //offset
...         },
...         count:{$sum:1}
...     }}
... ])
Run Code Online (Sandbox Code Playgroud)

结果

{ "_id" : { "day" : 10, "month" : 7, "year" : 2015 }, "count" : 1 }
{ "_id" : { "day" : 11, "month" : 7, "year" : 2015 }, "count" : 2 }
> 
Run Code Online (Sandbox Code Playgroud)

时区列表


Bla*_*ven 4

处理时区是一个“客户端”问题,因此您应该通过时区偏移量修改“查询”时间,以便允许在 UI 等中选择“本地”时间。UI 显示也是如此,其中日期将以当地时间表示。

这同样适用于你的聚合原则。只需调整时区偏移即可。应用日期数学而不是使用日期聚合运算符:

var tzOffset = 2;

db.txs.aggregate([
    { "$group": {
        "_id": { 
            "$subtract": [
                { "$add": [ 
                    { "$subtract": [ "$date", new Date("1970-01-01") ] },
                    tzOffset * 1000 * 60 * 60
                ]},
                { "$mod": [
                    { "$add": [ 
                        { "$subtract": [ "$date", new Date("1970-01-01") ] },
                        tzOffset * 1000 * 60 * 60
                    ]},
                    1000 * 60 * 60 * 24
                ]}
            ]
        },
        "count": { "$sum": 1 }
    }}
]).forEach(function(doc){ 
    printjson({ "_id": new Date(doc._id), "count": doc.count }) 
});
Run Code Online (Sandbox Code Playgroud)

这给你:

{ "_id" : ISODate("2015-07-10T00:00:00Z"), "count" : 1 }
{ "_id" : ISODate("2015-07-11T00:00:00Z"), "count" : 2 }
Run Code Online (Sandbox Code Playgroud)

因此,当您$subtract从另一个 BSON 日期获取一个 BSON 日期时,结果是自 Unix 纪元以来的毫秒数。然后,只需通过“添加”“时区偏移量”再次调整此值,该“时区偏移量”对于向前的小时为正,对于向后的小时为负,再次从时间值转换为有效的毫秒。

然后,四舍五入是一个简单的模数,$mod以获取“一天中的毫秒数”的余数,并将其删除,以仅将调整后的日期四舍五入到当天。

这里生成的数值很容易重新转换回日期,因为所有语言库“日期”对象都将纪元中的毫秒(或秒)作为构造函数参数。

再说一遍,这都是关于修改数据响应以从“客户端”的“区域设置”呈现,而不是更改数据的存储方式。如果您希望在应用程序中实现真正的局部性,那么您可以在任何地方应用时区偏移量的修改,就像上面介绍的那样。

--

实际上,您可以在聚合框架本身中创建日期,并进行更多的日期数学计算。只需将纪元日期添加回转换后的日期即可:

db.txs.aggregate([
    { "$group": {
        "_id": { 
            "$add": [
                { "$subtract": [
                    { "$add": [ 
                        { "$subtract": [ "$date", new Date(0) ] },
                        tzOffset * 1000 * 60 * 60
                    ]},
                    { "$mod": [
                        { "$add": [ 
                            { "$subtract": [ "$date", new Date(0) ] },
                            tzOffset * 1000 * 60 * 60
                        ]},
                        1000 * 60 * 60 * 24
                    ]}
                ]},
                new Date(0);
            ]
        },
        "count": { "$sum": 1 }
    }}
])
Run Code Online (Sandbox Code Playgroud)