我从lambda_B
22 次(异步)调用lambda_A
,单次lambda_B
调用在 3 秒内完成执行,所以根据这个,当我异步调用 22 lambda 时,它应该需要大约 3 秒的时间。但它需要时间 16-20 秒
这是我正在使用的示例代码
async callingLambda(arrayvalue) {
try {
const lambdaResponse = await BPromise.all(
arrayvalue.map((leg) => {
return new BPromise((resolve, reject) => {
const FunctionName = 'Lambda_B';
lambda.invoke({
FunctionName: FunctionName,
InvocationType: 'RequestResponse',
LogType: 'Tail',
Payload: JSON.stringify(reqParmaters)
}, function(error, data) {
if (error) {
reject(error);
} else {
resolve(body.errors.length ? null : body.data);
}
});
});
})
);
return lambdaResponse;
} catch (error) {
return BPromise.reject(error);
}
}
我几乎没有观察到,如果我将呼叫次数减少到 4-6 次,则大约需要 3 秒,但是当我增加呼叫次数时,时间也会增加。
根据我的研究,这个问题可能是由于没有。并行处理的 I/O 操作的nodejs
数量等于UV_THREADPOOL_SIZE
,默认值为UV_THREADPOOL_SIZE
4。
我也增加了大小,UV_THREADPOOL_SIZE
但它不起作用。