async 예
5862 단어 async
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);
}
}
);
}이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
【kintone】async/await 로 순서대로 데이터를 취득한다전회는 kintone.Promise.all 로 복수의 비동기 처리를 동시 병행으로 실행하면서, 전부 끝나면 다음의 처리를 실시···라고 하는 프로그램에 대해 썼습니다. 이번에는 async/await 로 다른 앱에서 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
