遍历mongodb某张数据库表(比如一亿数据),挨个访问记录,并作计算。 记录数每到
100的时候,将计算结果插入到redis。
这里有个问题:插入成功,再进行游标访问记录。 程序不好控制? Promise如何写?
如果不管三七二十一插入,redis操作会不会堵死?
谢谢。
var data_array = [];
dataCollection.find({'date' : {'$gt': starttime}}).forEach(function(doc) {
// 逐个获取collection记录的值
data_array.push(doc['somefield']);
if (data_array.length > 100) {
// 讲数组插入到redis
insert_to_redis(data_array);
data_array = [];
}
});
if (data_array.length > 0) {
insert_to_redis(data_array);
}
--
FROM 107.178.194.*