我正在尝试通过AWS lambda调用批处理操作。我希望批处理将输出返回到我的lambda

Question

我正在通过AWS Lambda调用批处理作业。输出可以在cloudwatch日志中看到，但我希望AWS批处理的输出显示在lambda日志中，因为我打算将API与lambda集成。Lambda是我的输入源。

代码：

import boto3
import json 
def lambda_handler(event, context): 
    client = boto3.client('batch') JOB_NAME = event["JobName"]
    JOB_QUEUE = "arn:aws:batch:ap-south-1:998338321653:job-queue/estimate-pi"
    JOB_DEFINITION = "arn:aws:batch:ap-south-1:998338321653:job-definition/test_batch_v2:12"
    response = client.submit_job(jobName = JOB_NAME, jobQueue = JOB_QUEUE, jobDefinition = JOB_DEFINITION, parameters = { "D": json.dumps(event)})
    print(response) 
    return (response)

Answer 1

一种可能的选择是使用您在提交亚马逊网络服务批次时收到的JobId来调用describeJobs API。然后，您可以从容器中获取logStream，并从lambda函数中获取logEvents。