1

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

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 行进行硬编码。有什么办法可以开启默认的重试机制，这样就可以默认继承到所有项目。

4

1 回答 1

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 以反映更改。
  5. 现在可以在 azkaban 项目中使用${retries}和访问该属性${retry.backoff}

参考文档：azkaban 文档

于 2018-02-02T10:09:06.960 回答