如何将runId传递给lambda的工作流触发的粘合作业? (蟒蛇)

目前,我知道,如果您使用start_job_run()直接触发参数,则可以将参数直接传递给胶粘作业。但是,如果我要触发一个工作流程,该工作流程随后触发该作业,但首先进行一些初始操作,该怎么办?我相信我可以设置工作流属性,但是为了使用get_workflow_run_properties()来检索它们,我需要将name(容易完成)和runId(不容易完成)作为参数,这有点像22。 >

我的触发代码:

def lambda_handler(event,context):
    glue_client = boto3.client("glue")
    workflow_name = os.environ["workflow_name"]
    try:
        response = glue_client.start_workflow_run(Name=workflow_name)
        run_id = response["RunId"]
    except Exception as e:
        logging.error(e)
    try:
        response = glue_client.put_workflow_run_properties(
        Name=workflow_name,RunId=run_id
        RunProperties={
            'runId': run_id,'someOtherParameter": "12345"
            }
        )
    except Exception as e:
        logging.error(e)

adi2589900 回答:如何将runId传递给lambda的工作流触发的粘合作业? (蟒蛇)

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3114513.html

大家都在问