擅长:python、mysql、java
<p>Azkaban作业运行时属性存储在env variable<strong>作业属性文件</strong>引用的文件中。在python程序中读取此文件并获取所需的属性。在</p>
<pre><code>import os
azkaban_job_prop_file = os.environ["JOB_PROP_FILE"]
with open(azkaban_job_prop_file,'r') as f:
print f.readline()
</code></pre>
<p>我们可以从这些属性推断作业名称<strong>azkaban.flow.nested.path</strong>和<strong>azkaban.job.metadata.file文件</strong></p>
<p>在azkaban.flow.nested.path->;如果作业是嵌入式DAG的一部分,则使用此选项。在</p>