如何解决boto3 lambda 负载始终返回 NULL [python,同步调用]
我正在使用 Lambda 来触发阶跃函数。它在触发阶跃函数方面工作正常,但我还需要 lambda 返回状态机执行 arn(不是状态机 arn)。我需要执行 arn,因为我将整个过程作为 github 操作工作流来实现,所以我需要它来检查状态机的状态(运行/成功/失败/中止)。
我为 github 操作获取 lambda 返回的代码,包装为 docker-compose 服务:
client = boto3.client("lambda",region_name="us-west-1")
lambda_response = client.invoke(
FunctionName="my-lambda",InvocationType="RequestResponse",Payload=json.dumps({"detail-type": "gh-action"}),)
payload = json.loads(lambda_response["Payload"].read()) # tried .decode() too
print("payload:",payload) # payload prints None as a whole,not {"sfn_exe_arn": None}
我的 lambda 函数的相关部分:
try:
client = boto3.client("stepfunctions")
response = client.start_execution(
stateMachineArn=STATE_MACHINE_ARN,name=run_name,input=json.dumps(
{"runName": run_name,"model_name": MODEL_NAME,"queries": QUERIES}
),)
sfn_exe_arn = response["executionArn"]
except Exception as e:
raise e
return {"sfn_exe_arn": sfn_exe_arn}
# this `sfn_exe_arn` can print out with expected value in console
# but it does not return when called in github action
当我从控制台调用这个 lambda 时,大多数时候它会按预期返回,即 {"sfn_exe_arn": sfn_exe_arn}
,但有时它也会返回 null
。
当我作为 github 操作工作流的一部分调用此 lambda 时,返回始终为 null
(返回 lambda_response
,只有 payload
部分始终为 null
)
谁能帮我理解为什么会有这个差距?显然我的 lambda 得到了 executionArn,但它只是没有返回到 client.invoke()
整个lambda_response
(在截图中被命名为response
):
解决方法
您必须解码从 StreamingBody.read() 获得的字节流
将 .decode()
添加到您从读取响应负载中获得的 bytes
对象。
payload = json.loads(lambda_response["Payload"].read().decode())
,
糟糕,我没有彻底尝试其他帖子的答案。谢谢@jarmod 在评论中指出了解决方案:您需要在读取之前将 StreamingBody
分配给变量。链接:Lambda Return Payload botocore.response.StreamingBody object prints but then empty in variable
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。