1.新建一个服务流,配置nodejs节点,如图所示
2.这个是完整代码
/**
- @param {Object} payload 上一节点的输出
- @param {Object} node 指定某个节点的输出
- @param {Object} query 服务流第一个节点的输出
- @param {Object} context { appKey, appSecret }
- @param {Object} global 变量
*/
module.exports = async function(payload, node, query, context, global) {
const redis = require('redis');
const client = redis.createClient(6379, "xxxxxx", {detect_buffers: true});
client.auth("xxxxx", xxxx)
client.on("error", function(error){
console.error("now redis connect" + error);
throw err;});
client.on("connect", function() {
console.log("now connect redis success");
});
const { promisify } = require("util");
const getAsync =promisify(client.get).bind(client);
var ll="";
await getAsync("foo_rand000000000000").then(
data=>{
console.log(222);
console.log(data)
ll =data
}).catch(console.error);
return ll;
}
注意: 直接写await是不起作用的 .必须放在promise前面 ,成对使用.
