文档章节

Mongodb aggregate timezone 问题

飓风2000
 飓风2000
发布于 2017/08/10 20:52
字数 512
阅读 6
收藏 0

在用aggregate 进行数据统计处理的时候,由于系统默认使用Mongodb的UTC时间,与我们时区差了8小时,会出现结果误差。为了获得正确的结果,在进行

aggregate 处理时需要在原来的基础上做加8小时处理。

测试数据如下

数据记录
下面我们来计算下shop_id 等于57300412且时间大于’2014-04-01T00:02:00Z’ 按天排序的统计结果。shell表达式如下

1

2

3

4

5

6

7

8

9

10

11

12

13

//经过时差处理

db.test.aggregate({$match:{'_id.shop_id':57300412}},

{$group:{

_id:{

year:{$year:{$add:['$_id.date',28800000]}},

month:{$month:{$add:['$_id.date',28800000]}},

day:{$dayOfMonth:{$add:['$_id.date',28800000]}

}},

amount:{$sum:'$value.amount'},

count:{$sum:'$value.count'},

cost:{$sum:'$value.cost'}}},

{$project:{_id:1,count:1,amount:1,cost:1}}

)

1

2

3

4

5

6

7

8

9

10

11

12

13

//没有经过时差处理

db.test.aggregate({$match:{'_id.shop_id':57300412}},

{$group:{

_id:{

year:{$year:'$_id.date'},

month:{$month:'$_id.date'},

day:{$dayOfMonth:'$_id.date'}

},

amount:{$sum:'$value.amount'},

count:{$sum:'$value.count'},

cost:{$sum:'$value.cost'}}},

{$project:{_id:1,count:1,amount:1,cost:1}}

)

对比结果如下

结果差值
注意上图增加时差和未增加时差的结果是不一样的。

说明:

1

2

$dayOfYear:计算日期的该年第几天,返回1366

$add:['$_id.date',28800000]: 时区数据校准,8小时换算成毫秒数为8*60*60*1000 = 28800000.

相应的Java代码片段如下:

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

DBObject match = new BasicDBObject("$match", new BasicDBObject("_id.shop_id", Integer.parseInt(shopAmount.getShopId())).

                append("_id.date", new BasicDBObject("$gte", startDate).append("$lte", endDate)));

 

BasicDBList dbList = new BasicDBList();

dbList.add("$_id.date");

dbList.add(28800000);//解决timezone 8小时时差

 

Map<String, Object> dbObjIdMap = new HashMap<String, Object>();

dbObjIdMap.put("year", new BasicDBObject("$year",new BasicDBObject("$add",dbList)));

dbObjIdMap.put("month", new BasicDBObject("$month",new BasicDBObject("$add",dbList)));

dbObjIdMap.put("dayOfMonth", new BasicDBObject("$dayOfMonth",new BasicDBObject("$add",dbList)));

DBObject groupFields = new BasicDBObject( "_id", new BasicDBObject(dbObjIdMap));

 

groupFields.put("amount", new BasicDBObject("$sum", "$value.amount"));

groupFields.put("count", new BasicDBObject("$sum", "$value.count"));

groupFields.put("cost", new BasicDBObject("$sum", "$value.cost"));

DBObject group = new BasicDBObject("$group", groupFields);

 

DBObject fields = new BasicDBObject("_id", 1);

fields.put("cost", 1);

fields.put("amount", 1);

fields.put("count", 1);

DBObject project = new BasicDBObject("$project", fields );

DBObject sort = new BasicDBObject("$sort", new BasicDBObject("_id", -1));

/* 查看Group结果 */

AggregationOutput output = collection.aggregate(match, group,project,sort); // 执行 aggregation命令

System.out.println(output.getCommandResult());

Collection<Object> c = output.getCommandResult().values();

Object o[] = c.toArray();

BasicDBList resultList = (BasicDBList) o[1];

本文转载自:

共有 人打赏支持
飓风2000
粉丝 36
博文 324
码字总数 135576
作品 0
浦东
高级程序员
私信 提问
。W/mongodb-weadmin

Mongodb-WeAdmin 项目介绍 Mongodb网页管理工具,基于Spring Boot2.0,前端采用layerUI实现。 源于线上环境部署mongodb时屏蔽了外网访问mongodb,所以使用不了mongochef这样方便的远程连接工具...

。W
2018/11/22
0
0
MongooseJS 4.11.4 发布,MongoDB 连接包

MongooseJS 4.11.4 发布了,MongooseJS 是使用 JavaScript 编程,连接 MongoDB 数据库的软件包,使 MongoDB 的文档数据模型变的优雅起来,方便对 MongoDB 文档型数据库的连接和增删改查等常规...

两味真火
2017/07/24
565
0
MongooseJS 4.1.0 发布,MongonDB 连接包

MongooseJS 4.1.0 发布,此版本更新内容如下: added; now public #3193 added; raw result as third parameter to findOneAndX callback #3173 added; ability to run validateSync() on o......

oschina
2015/07/27
909
0
MongooseJS 4.3.1 发布,MongoDB 连接包

MongooseJS 4.3.1 发布,此版本更新内容如下: feat(aggregate): helper #3665 fix(query): bitwise query operators with buffers #3663 docs(migration): clarify option and findByIdAnd......

oschina
2015/12/12
865
0
MongooseJS 4.7.5 发布,MongoDB 连接包

MongooseJS 4.7.5 发布了。Mongoose 基于 Nodejs,使用 JavaScript 编程,连接 MongoDB 数据库的软件包,使 MongoDB 的文档数据模型变的优雅起来,方便对 MongoDB 文档型数据库的连接和增删改...

局长
2016/12/27
696
0

没有更多内容

加载失败,请刷新页面

加载更多

Temp-Memo

Recommended Ref : SQL High CPU troubleshooting checklist -- Top 50 SQL highly consuming cpuSELECT TOP 50[Avg. MultiCore/CPU time(sec)] = qs.total_worker_time / 1000000 / qs......

Goopand
19分钟前
1
0
dotConnect for Oracle入门指南(七):存储过程

【下载dotConnect for Oracle最新版本】 dotConnect for Oracle(原名OraDirect.NET)建立在ADO.NET技术上,为基于Oracle数据库的应用程序提供完整的解决方案。它为设计应用程序结构带来了新的...

电池盒
21分钟前
2
0
如何使用阿里云ARMS轻松重现用户浏览器问题

客户投诉不断,本地却无法重现? 页面加载较慢是用户经常会反馈的问题,也是前端非常关注的问题之一。但定位、排查解决这类问题就通常会花费非常多的时间,主要原因如下: 页面是在用户端的浏...

阿里云官方博客
25分钟前
1
0
因资源用尽导致服务宕机

1. 事故的发生 服务调用场景和发生的事件如下图所示,红色表示服务不可用. 服务A和服务B都是内部服务,服务C_*为不同运营商提供的服务,遵循一样的协议。 某一天,突然发现所有服务A调用服务...

北风刮的不认真了
29分钟前
3
0
锤子科技"临死前"被"接盘" ,内部人士爆料已改签今日头条母公司

就在昨天,据据锤子科技内部人士透露,部分锤子科技员工在昨天已经接到了相关的临时通知,要求改签劳动合同至今日头条的母公司——字节跳动。至于这是锤子科技真正再度复活还是借尸还魂都不重...

终端研发部
39分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部