nodejs節點使用redis

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