我有一份胶水工作。我通过如下传递动态参数从 lambda 触发 Glue 作业。
glue.start_job_run(JobName=gluejobname,
Arguments=job_arguments)
现在,我有一个要求,根据我上面传递的
job_arguments
,每个作业运行成本应该归因于不同的团队。
例如。 对于第一次 Glue 运行,它接收名为
team
的参数,值为 team1
并运行 1 小时。
对于第二次 Glue 运行,它接收名为
team
的参数,其值为 team2
并运行 2 小时。
现在我想将首次运行成本归因于
team1
并将运行发送到team2
。我正在寻找通过 start_job_run
方法从 lambda 动态传递标签值的可能性。
我不想只为
team1
和team2
复制创建多个具有静态标签值的Glue作业,因为实际上有多个团队。