Utiliser des workflows

Pour configurer et exécuter un workflow, procédez comme suit :

1. Créez un modèle de workflow.
2. Configurez un cluster géré (éphémère) ou sélectionnez un cluster existant.
3. Ajoutez des tâches.
4. Instanciez le modèle pour exécuter le workflow.

Il est possible de paramétrer un modèle de workflow pour l'utiliser dynamiquement dans différents workflows. Il est également possible d'utiliser des fichiers YAML ou d'appeler l'API InstantiateInline pour définir et exécuter un workflow intégré, qui ne crée pas de ressources de modèle de workflow ni ne les modifie.

Créer un modèle

CLI gcloud

Exécutez la commande command suivante pour créer une ressource de modèle de workflow Dataproc.

gcloud dataproc workflow-templates create TEMPLATE_ID \
    --region=REGION

Remarques :

• REGION : spécifiez la région dans laquelle votre modèle s'exécutera.
• TEMPLATE_ID : indiquez un ID pour votre modèle, par exemple "workflow-template-1".
• Chiffrement CMEK Vous pouvez ajouter le paramètre --kms-key pour utiliser le chiffrement CMEK sur les arguments de tâche du modèle de workflow.

API REST

Envoyer un WorkflowTemplate faisant partie d'un workflowTemplates.create requête. Vous pouvez ajouter le champ WorkflowTemplate.EncryptionConfig.kmsKey pour utiliser le chiffrement CMEK sur les arguments de tâche du modèle de workflow. kmsKey

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Dataproc Workflows dans la console Google Cloud.

Configurer ou sélectionner un cluster

Dataproc peut soit créer et utiliser un nouveau cluster "géré" pour votre workflow, soit se servir d'un cluster existant.

• Cluster existant : consultez la page Utiliser des sélecteurs de cluster avec des workflows pour découvrir comment sélectionner un cluster existant pour votre workflow.

• Cluster géré : vous devez configurer un cluster géré pour votre workflow. Dataproc va créer ce cluster pour exécuter des tâches de workflow, puis le supprimer à la fin du workflow.

  Vous pouvez configurer un cluster géré pour votre workflow à l'aide de l'outil de ligne de commande gcloud ou de l'API Dataproc.

  Commande gcloud

  Utiliser les options héritées de gcloud dataproc cluster create pour configurer le cluster géré, comme le nombre de nœuds de calcul et le type de machine du maître et du nœud de calcul. Dataproc ajoute un suffixe le nom du cluster pour garantir son unicité. Vous pouvez utiliser l'option --service-account pour spécifier un compte de service de VM pour le cluster géré.

  gcloud dataproc workflow-templates set-managed-cluster TEMPLATE_ID \
      --region=REGION \
      --master-machine-type=MACHINE_TYPE \
      --worker-machine-type=MACHINE_TYPE \
      --num-workers=NUMBER \
      --cluster-name=CLUSTER_NAME
      --service-account=SERVICE_ACCOUNT
  

  API REST

  Consultez WorkflowTemplatePlacement.ManagedCluster, que vous pouvez fournir dans le cadre d'un WorkflowTemplate complet envoyé avec une requête workflowTemplates.create ou workflowTemplates.update.

  Vous pouvez utiliser GceClusterConfig.serviceAccount champ permettant de spécifier un compte de service de VM pour le cluster géré.

  Console

  Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Workflows Dataproc dans la console Google Cloud.

Ajouter des tâches à un modèle

Toutes les tâches sont exécutées simultanément, sauf si vous spécifiez une ou plusieurs dépendances de tâche. Celles-ci sont exprimées sous la forme d'une liste d'autres tâches qui doivent s'achever avant que la tâche finale puisse démarrer. Vous devez fournir un ID (step-id) pour chaque tâche. L'ID doit être unique dans le workflow, mais pas nécessairement à l'échelle globale.

Commande gcloud

Utilisez le type de tâche et les indicateurs hérités de gcloud dataproc jobs submit pour définir la tâche à ajouter au modèle. Vous pouvez inclure de façon facultative l'option ‑‑start-after job-id of another workflow job pour démarrer la tâche après la fin d'une ou de plusieurs autres tâches dans le workflow.

Actuellement, les options de tâches redémarrables --max-failures-per-hour et --max-failures-per-hour ne sont pas compatibles avec les tâches de modèle de workflow Dataproc.

Exemples :

Ajoutez la tâche Hadoop "foo" au modèle "my-workflow".

gcloud dataproc workflow-templates add-job hadoop \
    --region=REGION \
    --step-id=foo \
    --workflow-template=my-workflow \
    -- space separated job args

Ajoutez la tâche "bar" au modèle "my-workflow". Elle sera exécutée une fois la tâche du workflow "foo" achevée.

gcloud dataproc workflow-templates add-job JOB_TYPE \
    --region=REGION \
    --step-id=bar \
    --start-after=foo \
    --workflow-template=my-workflow \
    -- space separated job args

Ajoutez une autre tâche "baz" au modèle "my-workflow". Elle sera exécutée une fois les tâches "foo" et "bar" terminées.

gcloud dataproc workflow-templates add-job JOB_TYPE \
    --region=REGION \
    --step-id=baz \
    --start-after=foo,bar \
    --workflow-template=my-workflow \
    -- space separated job args

API REST

Consultez la section WorkflowTemplate.OrderedJob. Ce champ est fourni dans le cadre d'un WorkflowTemplate complet envoyé avec une requête WorkflowTemplates.create ou WorkflowTemplates.update.

Actuellement, les champs maxFailuresPerHour et maxFailuresTotal de OrderedJob.Jobscheduling ne sont pas compatibles avec les tâches de modèle de workflow Dataproc.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Workflows Dataproc dans la console Google Cloud.

Actuellement, l'option de tâche redémarrable Max restarts per hour n'est pas compatible avec les tâches de modèle de workflow Dataproc.

Exécuter un workflow

Instancier un modèle de workflow permet d'exécuter un workflow défini par le modèle. Les instanciations multiples d'un même modèle sont acceptées : vous pouvez exécuter un workflow plusieurs fois.

Commande gcloud

gcloud dataproc workflow-templates instantiate TEMPLATE_ID \
    --region=REGION

La commande renvoie un ID d'opération, que vous pouvez utiliser pour effectuer le suivi de l'état du workflow.

Exemple de commande et de résultat :

gcloud beta dataproc workflow-templates instantiate my-template-id \
    --region=us-central1
...
WorkflowTemplate [my-template-id] RUNNING
...
Created cluster: my-template-id-rg544az7mpbfa.
Job ID teragen-rg544az7mpbfa RUNNING
Job ID teragen-rg544az7mpbfa COMPLETED
Job ID terasort-rg544az7mpbfa RUNNING
Job ID terasort-rg544az7mpbfa COMPLETED
Job ID teravalidate-rg544az7mpbfa RUNNING
Job ID teravalidate-rg544az7mpbfa COMPLETED
...
Deleted cluster: my-template-id-rg544az7mpbfa.
WorkflowTemplate [my-template-id] DONE

API REST

Consultez la page WorkflowTemplates.instantiate.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Dataproc Workflows dans la console Google Cloud.

Échec d'une tâche de workflow

L'échec d'une tâche dans un workflow entraîne l'échec de celui-ci. Dataproc cherchera à en limiter les conséquences en provoquant l'échec de toutes les tâches exécutées simultanément et en empêchant le démarrage de tâches ultérieures.

Surveiller et répertorier un workflow

Commande gcloud

Pour surveiller un workflow :

gcloud dataproc operations describe OPERATION_ID \
    --region=REGION

Remarque : L'ID "operation-id" est renvoyé lorsque vous instanciez le workflow avec gcloud dataproc workflow-templates instantiate (consultez la section Exécuter un workflow).

Pour obtenir l'état du workflow :

gcloud dataproc operations list \
    --region=REGION \
    --filter="labels.goog-dataproc-operation-type=WORKFLOW AND status.state=RUNNING"

API REST

Pour surveiller un workflow, utilisez l'API operations.get Dataproc.

Pour répertorier les workflows en cours, utilisez l'API operations.list Dataproc avec un filtre de libellé.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Dataproc Workflows dans la console Google Cloud.

Supprimer un workflow

Vous pouvez mettre fin à un workflow à l'aide de la Google Cloud CLI ou en appelant l'API Dataproc.

Remarque : La suppression d'un workflow annule les tâches en cours et supprime le cluster géré (éphémère), le cas échéant.

Commande gcloud

gcloud dataproc operations cancel OPERATION_ID \
    --region=REGION

Remarque:L'operation-id est renvoyé lorsque vous instanciez le workflow avec gcloud dataproc workflow-templates instantiate (voir Exécuter un workflow).

API REST

Reportez-vous à la méthode operations.cancel API.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Workflows Dataproc dans la console Google Cloud.

Mettre à jour un modèle de workflow

Les mises à jour n'ont pas d'effet sur les workflows en cours d'exécution. La nouvelle version du modèle s'applique uniquement aux nouveaux workflows.

Commande gcloud

Les modèles de workflow peuvent être mis à jour en émettant de nouvelles commandes gcloud workflow-templates qui associent l'ID "template-id" d'un workflow existant :

• gcloud dataproc workflow-templates add job
• gcloud dataproc workflow-templates set-managed-cluster
• gcloud dataproc workflow-templates set-cluster-selector

à un modèle de workflow existant.

API REST

Pour mettre à jour un modèle avec l'API REST, procédez comme suit :

1. Appelez WorkflowTemplates.get qui affiche le modèle actuel avec le champ version renseigné selon la version actuelle du serveur.
2. Apportez des modifications au modèle récupéré.
3. Appelez WorkflowTemplates.update avec le modèle mis à jour.

Pour éviter les modifications simultanées, une demande de mise à jour d'un modèle doit spécifier la version actuelle du serveur dans le champ workflowTemplate.version.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Workflows Dataproc dans la console Google Cloud.

Supprimer un modèle de workflow

Commande gcloud

gcloud dataproc workflow-templates delete TEMPLATE_ID \
    --region=REGION

Remarque : L'ID "operation-id" est renvoyé lorsque vous instanciez le workflow avec gcloud dataproc workflow-templates instantiate (consultez la section Exécuter un workflow).

API REST

Consultez la page workflowTemplates.delete.

Console

Vous pouvez afficher les modèles de workflow existants et les workflows instanciés depuis la page Workflows Dataproc dans la console Google Cloud.