2024-03-28 21:05:49 发布
网友
我们需要从阿兹卡班的工作名称时,试图安排一个工作。有没有内置的物业?我们正在从${azkaban.job.flowid}获取流名称。在
${azkaban.job.flowid}
我的工作档案是:
type=command command=python xyz.py ${azkaban.job.attempt} ${azkaban.job.flowid}
找到了答案:
Azkaban作业运行如下 环境变量:
{ JOB_OUTPUT_PROP_FILE='xxx', JOB_PROP_FILE='xxx', JOB_NAME='xxx' }
可以通过以下Python代码段轻松获取作业名称:
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.path和azkaban.job.metadata.file文件
在azkaban.flow.nested.path->;如果作业是嵌入式DAG的一部分,则使用此选项。在
找到了答案:
Azkaban作业运行如下 环境变量:
可以通过以下Python代码段轻松获取作业名称:
^{pr2}$Azkaban作业运行时属性存储在env variable作业属性文件引用的文件中。在python程序中读取此文件并获取所需的属性。在
我们可以从这些属性推断作业名称azkaban.flow.nested.path和azkaban.job.metadata.file文件
在azkaban.flow.nested.path->;如果作业是嵌入式DAG的一部分,则使用此选项。在
相关问题 更多 >
编程相关推荐