Exemple de lanceur de flux parallèle

  • Rversion finale: Yokohama
  • Mis à jour 30 janv. 2025
  • 1 minute de lecture
  • Cet exemple montre comment utiliser l’activité Lanceur de flux parallèleavec un tableau de valeurs d’entrée et avec un objet WorkflowCoordinator.

    Exemple de workflow

    Cet exemple montre un serveur Web basé sur SQL avec quatre nœuds d’application. Un seul flux secondaire s’exécute pour mettre en service la base de données, et plusieurs flux secondaires parallèles configurent chacun un nœud d’application. Enfin, un ensemble distinct de flux secondaires parallèles configure les nœuds pour utiliser un équilibreur de charge et configure le DNS du serveur.

    Figure 1. Dossier métier du lanceur de flux parallèle

    Mettre en service les nœuds d’application

    La première activité de lanceur de flux parallèlelance le flux secondaire du nœud de mise en service quatre fois. L’activité transmet une adresse IP unique à chaque flux secondaire à partir d’un tableau dans la variable Entrées . Les scripts définis dans les variables de script Flux terminé et Fini écrivent des messages de journal concernant l’état des flux secondaires.
    Figure 2. Propriétés de l’activité du lanceur de flux parallèle

    Ajouter des nœuds à l’équilibreur de charge

    La deuxième activité de lanceur de flux parallèle utilise des objets WorkflowCoordinator pour spécifier les flux secondaires à exécuter. La variable de coordinateur stocke les informations de flux terminées provenant de l’activité précédente des nœuds de mise en service . Le script récupère ensuite l’adresse IP et le port pour chaque nœud qui a été mis en service. L’objet WorkflowCoordinator coord2 exécute le flux secondaire Ajouter un nœud à l’équilibreur de charge une fois pour chaque nœud, en utilisant l’adresse IP récupérée et les informations de port comme variables d’entrée. Enfin, l’objet coord2 WorkflowCoordinator exécute le flux secondaire SetupDNS une fois pour configurer l’équilibreur de charge.
    Figure 3. Spécification des flux secondaires à exécuter