目前,我知道,如果您使用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)