如何在azkaban 3.0中从作业文件中获取作业名称

Question

当试图安排作业时，我们需要来自Azkaban的作业名称。有什么内置属性吗？我们从${azkaban.job.flowid}获取流名称。

我的工作文件是：

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

Answer 1

Azkaban作业运行时属性存储在env变量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的一部分，请使用此命令。