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前面 ,成对使用.