|
@ -424,7 +424,7 @@ async function onCollection(err, collection) { |
|
|
|
|
|
|
|
|
var indexupdate = true |
|
|
var indexupdate = true |
|
|
//var indexfind1 = global.pipelines.findIndex(x => x.pathlogfile==pathfileval);
|
|
|
//var indexfind1 = global.pipelines.findIndex(x => x.pathlogfile==pathfileval);
|
|
|
await pubClient.hgetall(pathfileval, function(err, object) { |
|
|
var tmp1 = await pubClient.hgetall(pathfileval, function(err, object) { |
|
|
if(object){ |
|
|
if(object){ |
|
|
indexupdate = false |
|
|
indexupdate = false |
|
|
}else{ |
|
|
}else{ |
|
@ -450,7 +450,7 @@ async function onCollection(err, collection) { |
|
|
resobarray.push(resob1) |
|
|
resobarray.push(resob1) |
|
|
var resob1string = JSON.stringify(resob1); |
|
|
var resob1string = JSON.stringify(resob1); |
|
|
pubClient.hmset(pathfileval,resob1string) |
|
|
pubClient.hmset(pathfileval,resob1string) |
|
|
await pubClient.hgetall(pathfileval, function(err, object) { |
|
|
var tmp2 = await pubClient.hgetall(pathfileval, function(err, object) { |
|
|
console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> '+JSON.stringify(object)); |
|
|
console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> '+JSON.stringify(object)); |
|
|
}); |
|
|
}); |
|
|
//}
|
|
|
//}
|
|
|