python - 如何从Azkaban 3.0中的作业文件获取作业名称

我们在安排工作时需要Azkaban提供的工作名称。有没有内置的房产？我们正在从${azkaban.job.flowid}获取流名称。
我的工作档案是：

type=command
command=python xyz.py ${azkaban.job.attempt} ${azkaban.job.flowid}

最佳答案

Azkaban作业运行时属性存储在env variable job_PROP_file引用的文件中。在python程序中读取此文件并获取所需的属性。

import os
azkaban_job_prop_file = os.environ["JOB_PROP_FILE"]
with open(azkaban_job_prop_file,'r') as f:
        print f.readline()

我们可以从这些属性azkaban.flow.nested.path和azkaban.job.metadata.file中推断作业名称
azkaban.flow.nested.path->如果作业是嵌入DAG的一部分，则使用此选项。