如何从JobAZ0.3文件中获取JobAz0

2024-03-28 21:05:49 发布

您现在位置:Python中文网/ 问答频道 /正文

我们需要从阿兹卡班的工作名称时,试图安排一个工作。有没有内置的物业?我们正在从${azkaban.job.flowid}获取流名称。在

我的工作档案是:

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

Tags: py名称typejob档案内置commandazkaban
2条回答

找到了答案:

Azkaban作业运行如下 环境变量:

{ JOB_OUTPUT_PROP_FILE='xxx',
  JOB_PROP_FILE='xxx',
  JOB_NAME='xxx' }

可以通过以下Python代码段轻松获取作业名称:

^{pr2}$

Azkaban作业运行时属性存储在env variable作业属性文件引用的文件中。在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.pathazkaban.job.metadata.file文件

在azkaban.flow.nested.path->;如果作业是嵌入式DAG的一部分,则使用此选项。在

相关问题 更多 >