est-il possible de lancer quelques workflows oozie avec un seul coordinateur?

Question

Je ne suis pas sûr d'utiliser le bon outil pour ce que je veux.

J'ai beaucoup de flux de travail qui peuvent être dépendants ou non.

Exemple:

1. /Workflow1
   • /workflow.xml
   • /job.properties
2. /workflow2
   • /workflow.xml
   • /job.properties
3. ....

Je pensais que nous pouvons avoir une corrdinator qui peut lancer (avec certaines conditions de données) tout le flux de travail. Mais je commence à penser que ce n'est pas la bonne pratique.

Devrions-nous avoir un coordinateur par workflow avec toutes les conditions d'exécutions + un bundle qui lance tout le coodinator? comme ça:

1. /WF1
   • /workflow.xml
   • /job.properties
   • /coordinator.xml
2. /WF2
   • /flux de travail. xml
   • /j ob.properties
   • /coordinator.xml
3. /bundle.xml

OU un coordonnateur peut lancer tout le flux de travail (ils peuvent être dépendants ou non)?

1. /WF1
   • /workflow.xml
   • /job.properties
2. /WF2
   • /workflow.xml
   • /job.properties
3. /coordinateur.xml

Answer 1

Cela dépend. Si wf1 et wf2 sont logiquement liés, ont la même fréquence et ont des dépendances de jeu de données communes, vous pouvez les mettre par un coordinateur (et les exécuter simultanément ou les unes après les autres). Mais s'ils ne le sont pas, il vaut mieux les mettre dans des coordinateurs séparés.

Vous pouvez lancer plusieurs flux de travail d'une aide de la fonction sub-workflow:

<workflow-app name="root-workflow" xmlns="uri:oozie:workflow:0.4"> 
    <start to="run-wf1"/> 
    <action name="run-wf1"> 
     <sub-workflow> 
      <app-path>${appPath}/wf1.xml</app-path> 
      <propagate-configuration/> 
     </sub-workflow> 
     <ok to="run-wf2"/> 
     <error to="kill"/> 
    </action> 
    <action name="run-wf2"> 
     <sub-workflow> 
      <app-path>${appPath}/wf2.xml</app-path> 
      <propagate-configuration/> 
     </sub-workflow> 
     <ok to="end"/> 
     <error to="kill"/> 
    </action> 
    <kill name="kill"> 
     <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message> 
    </kill> 
    <end name="end"/> 
</workflow-app> 

Si vous souhaitez les exécuter simultanément que l'utilisation de bifurquer.