Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

État du flux de travail des tâches

Un état Task ("Type": "Task") représente une seule unité de travail effectuée par une machine d'état. Une tâche exécute un travail à l'aide d'une activité ou d'un AWS Lambda fonction, en s'intégrant à d'autres supports Services AWS, ou en faisant appel à un tiersAPI, tel que Stripe.

L'Amazon States Language représente les tâches en définissant le type d'état Task et en fournissant à la tâche le nom de ressource Amazon (ARN) de l'activité, de la fonction Lambda ou du point de terminaison tiersAPI. La définition d'état de tâche suivante invoque une fonction Lambda nommée. HelloFunction

"Lambda Invoke": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-2:123456789012:function:HelloFunction:$LATEST"
  },
  "End": true
}

Types de tâches

Step Functions prend en charge les types de tâches suivants que vous pouvez spécifier dans une définition d'état de tâche :

Vous spécifiez un type de tâche en le fournissant ARN dans le Resource champ de définition de l'état d'une tâche. L'exemple suivant montre la syntaxe du Resource champ. Tous les types de tâches, à l'exception de celui qui invoque un tiersAPI, utilisent la syntaxe suivante. Pour plus d'informations sur la syntaxe de la HTTP tâche, consultezAppelez un tiers APIs dans les flux de travail Step Functions.

Dans la définition de l'état de votre tâche, remplacez le texte en italique dans la syntaxe suivante par AWS informations spécifiques aux ressources.

arn:partition:service:region:account:task_type:name

La liste suivante décrit les différents composants de cette syntaxe :

Les sections suivantes fournissent plus de détails sur chaque type.

Activité

Les activités représentent les applications de travail (procédés ou threads), implémentées et hébergées par vous, qui effectuent une tâche spécifique. Ils sont pris en charge uniquement par les workflows standard, mais pas par les workflows express.

L'activité Resource ARNs utilise la syntaxe suivante.

arn:partition:states:region:account:activity:name

Pour plus d'informations sur la création d'une activité et la mise en œuvre de programmes exécutants, consultez la section Activités.

Fonctions Lambda

Les tâches Lambda exécutent une fonction en utilisant AWS Lambda. Pour spécifier une fonction Lambda, utilisez ARN la fonction Lambda dans le champ. Resource

En fonction du type d'intégration (intégration optimisée ou AWS SDKintegration) que vous utilisez pour spécifier une fonction Lambda, la syntaxe du champ de votre fonction Lambda varie. Resource

La syntaxe de Resource champ suivante est un exemple d'intégration optimisée avec une fonction Lambda.

"arn:aws:states:::lambda:invoke"

La syntaxe de Resource champ suivante est un exemple de AWS SDKintégration avec une fonction Lambda.

"arn:aws:states:::aws-sdk:lambda:invoke"

La définition Task d'état suivante montre un exemple d'intégration optimisée avec une fonction Lambda nommée. HelloWorld

"LambdaState": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "OutputPath": "$.Payload",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-1:function:HelloWorld:$LATEST"
  },
  "Next": "NextState"
}

Une fois que la fonction Lambda spécifiée dans le Resource champ est terminée, sa sortie est envoyée à l'état identifié dans le Next champ (» NextState «).

A pris en charge Service AWS

Lorsque vous référencez une ressource connectée, Step Functions appelle directement les API actions d'un service pris en charge. Spécifiez le service et l'action dans le champ Resource.

Le service connecté Resource ARNs utilise la syntaxe suivante.

arn:partition:states:region:account:servicename:APIname

Par exemple :

{
 "StartAt": "BATCH_JOB",
 "States": {
   "BATCH_JOB": {
     "Type": "Task",
     "Resource": "arn:aws:states:::batch:submitJob.sync",
     "Parameters": {  
       "JobDefinition": "preprocessing",
       "JobName": "PreprocessingBatchJob",
       "JobQueue": "SecondaryQueue",
       "Parameters.$": "$.batchjob.parameters",
       "RetryStrategy": {
          "attempts": 5
        }
     },
     "End": true
    }
  }
}

Champs d'état des tâches

Outre les champs d'état courants, les états Task ont les champs suivants.

Un état Task doit définir le champ End sur true si l'état termine l'exécution ou doit fournir un état dans le champ Next qui sera exécuté lors de la fin de l'état Task.

Exemples de définition de l'état des tâches

Les exemples suivants montrent comment vous pouvez spécifier la définition de l'état de la tâche en fonction de vos besoins.

État des tâches, délais d'expiration et intervalles entre les pulsations

Il est recommandé de définir un délai d'expiration et un intervalle de pulsation pour les activités de longue durée. Cela peut être fait en spécifiant le délai d'expiration et les valeurs du rythme cardiaque, ou en les réglant dynamiquement.

Exemple de délai d'expiration statique et de notification du rythme cardiaque

Une fois HelloWorld terminé, l'état suivant (appelé ici NextState) est exécuté.

Si cette tâche échoue dans un délai de 300 secondes ou n'envoie pas de notifications relatives aux pulsations par intervalles de 60 secondes, la tâche est marquée comme failed.

"ActivityState": {
  "Type": "Task",
  "Resource": "arn:aws:states:us-east-1:123456789012:activity:HelloWorld",
  "TimeoutSeconds": 300,
  "HeartbeatSeconds": 60,
  "Next": "NextState"
}

Exemple de délai d'expiration d'une tâche dynamique et de notification du rythme cardiaque

Dans cet exemple, lorsque AWS Glue le travail est terminé, l'état suivant sera exécuté.

Si cette tâche ne s'exécute pas dans l'intervalle défini dynamiquement par le AWS Glue tâche, la tâche est marquée commefailed.

"GlueJobTask": {
  "Type": "Task",
  "Resource": "arn:aws:states:::glue:startJobRun.sync",
  "Parameters": {
    "JobName": "myGlueJob"
  },
  "TimeoutSecondsPath": "$.params.maxTime",
  "Next": "NextState"
}

Exemples de champs d'informations d'identification de l'état de la tâche

Spécification d'un rôle codé en dur IAM ARN

L'exemple suivant spécifie un IAM rôle cible que le rôle d'exécution d'une machine à états doit assumer pour accéder à une fonction Lambda entre comptes nommée. Echo Dans cet exemple, le rôle cible ARN est spécifié sous forme de valeur codée en dur.

{
  "StartAt": "Cross-account call",
  "States": {
    "Cross-account call": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn": "arn:aws:iam::111122223333:role/LambdaRole"
      },
      "Parameters": {
        "FunctionName": "arn:aws:lambda:us-east-2:111122223333:function:Echo"
      },
      "End": true
    }
  }
}

Spécification en JSONPath tant que IAM rôle ARN

L'exemple suivant spécifie une JSONPath valeur, qui sera convertie en IAM rôle ARN lors de l'exécution.

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "$.roleArn"
      },
      ...
    }
  }
}

Spécifier une fonction intrinsèque en tant que IAM rôle ARN

L'exemple suivant utilise la fonction States.Formatintrinsèque, qui correspond à un IAM rôle ARN lors de l'exécution.

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "States.Format('arn:aws:iam::{}:role/ROLENAME', $.accountId)"
      },
      ...
    }
  }
}