我可以使用多次调用的 oozie 操作作为模板吗？

Question

我有一个 shell oozie 操作，它接收许多传递给 shell 脚本的参数。我想每次使用不同的参数多次触发该操作。一个示例 dag 看起来像：

    Start
   /  |  \
f(a) f(d) f(g)
 |    |    |
 V    V    V
f(b) f(e) f(h)
 |    |    |
 V    V    V
f(c) f(f) f(i)
   \  |  /
     End

是否可以在没有一堆重复操作的情况下实现这一目标？

Answer 1

是的，可以使用 Oozie sub-workflow 选项。

将Shell动作组成一个子工作流，并从主工作流的许多地方调用子工作流，输入值不同。

    <action name="call_sub_workflow_1">
      <sub-workflow>
          <app-path>${workflowAppUri}/sub_workflow_with_shell_action/</app-path>
          <propagate-configuration/>
          <configuration>
              <property>
                  <name>argument_1</name>
                  <value>${wf:actionData('previous_action')['val1']}</value>
              </property>
              <property>
                  <name>argument_2</name>
                  <value>${val2}</value>
              </property>
          </configuration>
      </sub-workflow>
      <ok to="End"/>
      <error to="Fail"/>
    </action>

具有子工作流程目录结构的主工作流程如下所示，

   main_workflow_dir
   |
   |--job.properties
   |
   |--workflow.xml  # main workflow, can call sub workflow from multiple places
   |
   |--sub_workflow_with_shell_action
       |
       |--shell script
       |
       |--workflow.xml  # sub workflow contains the shell script action and takes arguments

我可以使用多次调用的 oozie 操作作为模板吗？

Can I use an oozie action as a template that I call many times?

directed-acyclic-graphs

oozie

oozie-workflow