使用 boto 调用 lambda 不遵守超时

invoking lambda with boto doesn't respect timeout

我正在使用 boto3 调用 lambda 函数,其中:

import boto3
import json

client = boto3.client('lambda')
response = client.invoke(
            InvocationType='RequestResponse',
            FunctionName=test_lambda_arn,
            LogType='Tail',
            Payload=json.dumps(data)
)

它在 626 秒后引发 botocore.vendored.requests.exceptions.ReadTimeout 异常。我已将此 lambda 配置为在 100 秒后超时。当我用 boto 创建它时,我这样做了。当我进入 AWS 控制台时,它说这个 lambda 有 1 分 40 秒的超时。

那么为什么 invoke 命令在 626 秒后超时,而不是在 100 秒后超时?

是重试的原因吗?如果是这样,我该如何禁用重试?

编辑:在 CloudWatch 日志中,我可以看到每个 client.invoke 调用都有多个调用。因此会发生一些自动重试的事情。 client.invoke.

the docs

我在 boto3 git 存储库上发布了这个问题。他们将向 client.invoke 添加一个选项以禁用自动重试。

同时,here's a workaround

创建一个 botocore config 具有更长 read_timeout 值(可能还有其他东西)的对象,并在创建您的 lambda 客户端时将其传入:

import botocore
import boto3
            
cfg = botocore.config.Config(retries={'max_attempts': 0}, read_timeout=840, connect_timeout=600, region_name="us-east-1" )
           
client = boto3.client(
    'lambda', config=cfg, region_name="us-east-1",
     aws_access_key_id="*********", aws_secret_access_key="*********")

payload = {"input_array": input_arr}

result = client.invoke(
     FunctionName="**********", InvocationType='RequestResponse',
     LogType='Tail', Payload=json.dumps(payload,cls=NumpyArrayEncoder))
        

range = result['Payload'].read()
range_json = json.loads(range)