使用 NODE JS 和 BLUEBIRD 从 REDIS 中获取数据
Fetching data from REDIS with NODE JS and BLUEBIRD
我正在尝试获取特定键模式的所有条目并使回调整齐地发生,我正在使用 Bluebird。项目的nodejs的redis客户端是node_redis
redis客户端中的代码为-
exports.getAllRedisKeysA = function() {
var res = rclient.keysAsync("client*").then(function(data) {
// console.log(data);
}).then(function(data) {
var arrayResp = [];
for (var element in data) {
rclient.hgetallAsync(element).then(function(data) {
arrayResp.push(data);
});
};
return arrayResp;
// console.log(data);
}).catch(console.log.bind(console));
console.log(res); // gives an empty promise.
return res;
}
并且这个函数是通过以下方式从控制器调用的 -
var abc = rdata.getAllRedisKeysA();
// console.log(abc); // gives undefined
redis 函数内部的 console.log 输出给出了一个空承诺,没有任何内容返回给控制器。
我在实施过程中遗漏了什么吗?
Linus and Jaromanda 对帮助我朝着正确方向前进的问题提出了一些真正有用的评论。我已经使用以下方法使用 BlueBird Promise 从 REDIS 获取我需要的数据,这是需要完成的方法。
下面的代码从REDIS
获取所需的数据
exports.getRedisKeyPattern = function(pattern){
var allKeys = allKeysPattern(pattern).then(function(data){
var arrayResp = [];
var inptArr = [];
var newdata = data.slice(1)[0];
for(var i in newdata){
inptArr.push(newdata[i]);
};
return new Promise.resolve(inptArr);
});
var valuePerKey = Promise.mapSeries(allKeys, function(dt){
return getAllKeyContents(dt);
}).then(function(res){
return res;
}).catch(function(err) { console.log("Argh, broken: " + err.message);
});
return new Promise.resolve(valuePerKey);
}
function getAllKeyContents(key){
var data = rclient.hgetallAsync(key).then(function(data){
return data;
}).catch(function(err) { console.log("Argh, broken: " + err.message); });
var res = Promise.join(data, key, function(data, key){
return {
key: key,
data: data
};
});
return res;
}
在控制器中,函数是这样调用的 -
var rdata = require('../../components/redis/redis-functions');
rdata.getRedisKeyPattern("clients*").then(function(response){
return res.status(200).json(response);
});
包含redis函数的.js文件被包含到控制器文件中,以便可以使用函数。
我正在尝试获取特定键模式的所有条目并使回调整齐地发生,我正在使用 Bluebird。项目的nodejs的redis客户端是node_redis
redis客户端中的代码为-
exports.getAllRedisKeysA = function() {
var res = rclient.keysAsync("client*").then(function(data) {
// console.log(data);
}).then(function(data) {
var arrayResp = [];
for (var element in data) {
rclient.hgetallAsync(element).then(function(data) {
arrayResp.push(data);
});
};
return arrayResp;
// console.log(data);
}).catch(console.log.bind(console));
console.log(res); // gives an empty promise.
return res;
}
并且这个函数是通过以下方式从控制器调用的 -
var abc = rdata.getAllRedisKeysA();
// console.log(abc); // gives undefined
redis 函数内部的 console.log 输出给出了一个空承诺,没有任何内容返回给控制器。
我在实施过程中遗漏了什么吗?
Linus and Jaromanda 对帮助我朝着正确方向前进的问题提出了一些真正有用的评论。我已经使用以下方法使用 BlueBird Promise 从 REDIS 获取我需要的数据,这是需要完成的方法。
下面的代码从REDIS
获取所需的数据exports.getRedisKeyPattern = function(pattern){
var allKeys = allKeysPattern(pattern).then(function(data){
var arrayResp = [];
var inptArr = [];
var newdata = data.slice(1)[0];
for(var i in newdata){
inptArr.push(newdata[i]);
};
return new Promise.resolve(inptArr);
});
var valuePerKey = Promise.mapSeries(allKeys, function(dt){
return getAllKeyContents(dt);
}).then(function(res){
return res;
}).catch(function(err) { console.log("Argh, broken: " + err.message);
});
return new Promise.resolve(valuePerKey);
}
function getAllKeyContents(key){
var data = rclient.hgetallAsync(key).then(function(data){
return data;
}).catch(function(err) { console.log("Argh, broken: " + err.message); });
var res = Promise.join(data, key, function(data, key){
return {
key: key,
data: data
};
});
return res;
}
在控制器中,函数是这样调用的 -
var rdata = require('../../components/redis/redis-functions');
rdata.getRedisKeyPattern("clients*").then(function(response){
return res.status(200).json(response);
});
包含redis函数的.js文件被包含到控制器文件中,以便可以使用函数。