Skip to main content

阿兹卡班服务调用

访问路径：数据抽取 -> Restful服务调用 -> 阿兹卡班服务调用

功能简述​

该功能模块提供了远程调用Azkaban中预定义工作流的能力，同时依据配置内容，可以在启动任务流后立即返回，或一直等待任务直接完成或失败。

服务定义​

Azkaban服务只需定义到服务（数据库）层级即可，同时，配置相应的服务访问账号即可调用。

配置界面​

Azkaban Config

主要配置项如下：

  • Restful API：选择预定义的Azkaban服务地址
  • 项目名称：配置在Azkaban平台上的项目名称（任务流集合名）
  • 流程名称：特定的任务流，即当前需要处理的任务流程
  • 需要等待流程执行完成：该选项决定了调用Azkaban任务流后系统的处理方式，如果未选择，则在调用后立即返回成功，并继续执行Hamster平台后续任务。否则，将持续等待（5分钟检测一次）并检测任务流的执行状态，直至任务完成或失败。
    • 如果Azkaban任务执行失败，如FAILED（执行失败）、KILLED(流程被人工取消)，都将触发仓鼠系统的异常报错，并停止继续执行。
    • 如果仓鼠当前执行的任务被取消了，也会导致正在运行的Azkaban任务被联动取消。
  • 反馈结果参数：该参数为用户自定义的字符型变量，用于保存任务运行结果状态，便于在后续任务中使用。

下图为一次Azkanba任务调用的案例。

Invoke Log