async样例
2024-09-07 06:09:30
function iniProcessDetail(isjob) {
var cursor = logColl.find({}).sort({ip: 1});
var insertbolk = [];
var eveipobj = {};
var hasinsertdetail = 0;
var goNext = true; function InsertDbs(teminsert) {
console.log("will insert" + teminsert.length);
(function (insertbolk) {
logprocessDetailColl.insert(insertbolk, function (err) {
hasinsertdetail += insertbolk.length;
console.log("insert insertprocessDetails count" + hasinsertdetail);
});
})(teminsert)
insertbolk = [];
} async.whilst(
function () {
return goNext;
},
function (callback) {
cursor.nextObject(function (err, item) {
// less 1
// if (insertbolk.length == 1000) {
// InsertDbs(insertbolk);
// }
if (item) {
setTimeout(function () {
function inieveipobj(eveipobj, item) {
eveipobj._id = eveipobj._id || item.ip;
eveipobj.value = eveipobj.value || {};
eveipobj.value.arr = eveipobj.value.arr || [];
return eveipobj;
} eveipobj = inieveipobj(eveipobj, item);
if (eveipobj._id != item.ip) {
(function (eveipobj) {
var prodetail = ipMeta.getProcessDetail(eveipobj)
insertbolk.push(prodetail);
})(eveipobj)
eveipobj = {};
eveipobj = inieveipobj(eveipobj, item);
}
var obj = {}
obj.gps = item.gps;
obj.created = item.created;
eveipobj.value.arr.push(obj);
if (insertbolk.length == 1000) {
InsertDbs(insertbolk);
}
callback();
}, 5); } else {
goNext = false;
callback();
}
})
},
function (err) {
if (insertbolk.length > 0) {
InsertDbs(insertbolk);
}
console.log('No Map/Reduce IniProdetails Finished', err);
if (isjob) {
fromDetailTolocation(isjob);
}
}
);
}
最新文章
- 阿里云提示Discuz uc.key泄露导致代码注入漏洞uc.php的解决方法
- SQL存储过程解密
- 数的统计count(bzoj1036)
- LightOJ1051 Good or Bad(DP)
- html5添加音乐包括暂停
- proguard使用
- POJ 1286 Necklace of Beads(Polya原理)
- #你好Unity3D#Hierarchy视图监听gameObject点击事件
- Android学习及开发随记1:Android Studio安装配置
- 关于Vim的问题s
- [RxJS] Drag and Drop example
- Eclipse 编译StanfordNLP
- Android学习总结——SQLite
- 在IE浏览器中iframe跨域访问cookie/session丢失的解决办法
- HTTP认证方式与https简介
- Problem : 1002 ( A + B Problem II )
- hdu 2254(矩阵)
- 如何使用python在保留原excel格式的前提下插入/修改数据
- Python装饰器举例分析
- asp.net query string 及 form data 遇到的编码问题
热门文章
- MyBatis项目报错:The server time zone value '�й�' is unrecognized or represents more than one time zone
- springboot跨域请求接口示例
- [LC] 51. N-Queens
- 66)vector基础总结
- Constant expression required
- PAT甲级——1073 Scientific Notation (20分)
- Charles 安装配置
- CSP模拟赛游记
- Window命令行切换命令
- 通过Dockerfile 文件为linux images 添加新用户