我有一个使用节点12的lambda函数。

我需要将新连接添加到托管在AWSElastiCache中的Redis数据库。

两者都在一个私有VPC并且安全组/子网配置正确。

解决方案：

global. js：

const redis = require('redis');
const redisClient = redis.createClient(
  `redis://${process.env.REDIS_HOST}:${process.env.REDIS_PORT}/${process.env.REDIS_DB}`,
);
redisClient.on('error', (err) => {
  console.log('REDIS CLIENT ERROR:' + err);
});
module.exports.globals = {
  REDIS: require('../helpers/redis')(redisClient),
};

index. js（外部处理程序）：

const { globals } = require('./config/globals');
global.app = globals;

const lambda_handler = (event, context, callback) => { ... }
exports.handler = lambda_handler;

助手/redis/index. js：

const get = require('./get');
module.exports = (redisClient) => {
  return {
    get:  get(redisClient)
  };
};

助手/redis/get. js：

module.exports = (redisClient) => {
  return (key, cb) => {
    redisClient.get(key, (err, reply) => {
      if (err) {
        cb(err);
      } else {
        cb(null, reply);
      }
    });
  };
};

函数调用：

app.REDIS.get(redisKey, (err, reply) => {
  console.log(`REDIS GET: ${err} ${reply}`);
});

问题：当将lambda超时增加到大于Redis超时的值时，我收到这个错误：

REDIS客户端错误：错误：Redis连接到…失败-连接ETIMEDOUT…

添加：

我尝试在每个事务后退出/关闭连接：

module.exports = (redisClient) => {

  return (cb) => {

    redisClient.quit((err, reply) => {
      if (err) {
        cb(err);
      } else {
        cb(null, reply);
      }
    });
  };
};

app.REDIS.get(redisKey, (err, reply) => {
  console.log(`REDIS GET: ${err} ${reply}`);
  if (err) {
    cb(err);
  } else {
    if (reply) {
      app.REDIS.quit(() => {
        cb()
      });
    }
  }
})

错误：

REDIS GET： AbortError：GET无法处理。连接已关闭。

额外说明：

• 我必须使用回调，这就是为什么我在上面的示例中传递one
• 我正在使用"redis"："^3.0.2"
• 这不是配置问题，因为缓存在短时间内被访问了数百次，但随后它开始给出超时错误。
• 本地一切正常