AWS Lambda:Redis ElastiCache连接超时错误

Question

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

我需要添加一个新的连接到托管在AWS ElastiCache中的Redis数据库。

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

解决方案：

globals.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;

helpers/redis/index.js:

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

helpers/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：中止错误：无法处理GET。连接已关闭。

额外注释：

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

Answer 1

这不是配置问题，因为缓存在短时间内被访问了数百次，但随后开始出现超时错误。

我认为这是问题的根源，可能redis数据库大小达到了大小限制，并且无法处理新数据？

你能删除里面的旧数据吗？

此外，Elastic Cache可能对新TCP客户端的连接有限制，如果它已耗尽，新连接将被拒绝，并显示您提到的类似错误消息。

如果aws lambda函数中的redis客户端无法建立连接，则aws lambda函数将失败，并启动新的函数。新的lambda函数又与redis建立了一个连接，redis无法处理它，并且又启动了一个lambda函数。。。

所以，有一刻，我们达到了活动redis连接的限制，系统处于死锁状态。

我认为您可以暂时停止所有lambda函数，并扩展ElasticCache-reis数据库。