python - 如何在Azkaban中启用默认重试机制

Question

有一种方法可以指定作业中的重试，如下所示

from azkaban import Job, Project
project = Project('azkaban_basic_flow', root=__file__)
project.properties['retries'] = '3' #line 3
project.properties['retry.backoff'] = '60000' #line 4

假设我们有 10 个项目 - 我们需要对所有 10 个项目中的第 3 行和第 4 行进行硬编码。有什么办法可以启用默认的重试机制，使其默认继承到所有项目中。

Answer 1

全局级别的属性应该在 common.properties 中定义，并且可以在 azkaban 项目中使用。(azkaban-version:3.1.0)

遵循的步骤:

1. 导航到azkaban-exec-server-0.1.0-SNAPSHOT/plugins/jobtypes/并创建common.properties
2. 将内容放入 common.properties retries=3
retry.backoff=30000
3. 使用 azkaban-exec-server-0.1.0-SNAPSHOT/plugins/jobtypes/jobtype-name/plugin.properties 内的 common.properties 中定义的属性。
4. 重新启动 azkaban-executor 以反射(reflect)更改。
5. 现在可以使用 ${retries} 和 ${retry.backoff} 在 azkaban 项目内部访问该属性

引用文档:azkaban documentation