Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Estado del flujo de trabajo de tareas

Un estado Task ("Type": "Task") representa una única unidad de trabajo realizada por una máquina de estado. Una tarea realiza el trabajo mediante una actividad o AWS Lambda función, mediante la integración con otras compatibles Servicios de AWS o mediante la invocación de un terceroAPI, como Stripe.

El lenguaje Amazon States representa las tareas estableciendo el tipo de estado Task y proporcionando a la tarea el nombre del recurso de Amazon (ARN) de la actividad, la función Lambda o el punto final de tercerosAPI. La siguiente definición de estado de tarea invoca una función de Lambda denominada 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
}

Tipos de tareas

Step Functions es compatible con los siguientes tipos de tareas, que se pueden especificar en una definición de estado de tarea:

Para especificar un tipo de tarea, debe proporcionarlo ARN en el Resource campo de una definición de estado de tarea. En el ejemplo siguiente se muestra la sintaxis del campo Resource. Todos los tipos de tareas, excepto el que invoca a un terceroAPI, utilizan la siguiente sintaxis. Para obtener información sobre la sintaxis de la HTTP tarea, consulteLlama a terceros APIs en los flujos de trabajo de Step Functions.

En la definición del estado de la tarea, sustituya el texto en cursiva de la siguiente sintaxis por la información específica del AWS recurso.

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

En la lista siguiente, se explican los componentes individuales de esta sintaxis:

En las secciones siguientes, se proporcionan más detalles sobre cada tipo de tarea.

Actividad

Las actividades representan procesos o subprocesos de trabajo implementados y alojados por usted, que realizan una tarea específica. Solo son compatibles con los flujos de trabajo estándar, pero no con los flujos de trabajo rápidos.

La actividad Resource ARNs utiliza la siguiente sintaxis.

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

Para obtener más información sobre la creación de una actividad y la implementación de procesos de trabajo, consulte Actividades.

Funciones de Lambda

Las tareas Lambda ejecutan una función mediante. AWS Lambda Para especificar una función Lambda, utilice la función Lambda ARN del campo. Resource

Según el tipo de integración (integración optimizada o AWS SDKintegración) que utilice para especificar una función Lambda, la sintaxis del campo de la función Lambda varía. Resource

La siguiente sintaxis del campo Resource es un ejemplo de una integración optimizada con una función de Lambda.

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

La siguiente sintaxis de Resource campo es un ejemplo de una AWS SDK integración con una función Lambda.

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

La siguiente definición del estado Task muestra un ejemplo de una integración optimizada con la función de Lambda denominada 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"
}

Una vez completada la función Lambda especificada en el Resource campo, su salida se envía al estado identificado en el Next campo (» NextState «).

A compatible Servicio de AWS

Cuando haces referencia a un recurso conectado, Step Functions llama directamente a las API acciones de un servicio compatible. Especifique el servicio y la acción en el campo Resource.

Los servicios conectados Resource ARNs utilizan la siguiente sintaxis.

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

Por ejemplo:

{
 "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
    }
  }
}

Campos de estado de tarea

Además de los campos de estado comunes, los estados Task, disponen de los siguientes campos:

Un estado Task debe establecer el campo End en true si el estado finaliza su ejecución, o bien debe proporcionar un estado en el campo Next que se ejecuta cuando finaliza el estado Task.

Ejemplos de definición de estado de tarea

En los siguientes ejemplos se muestra cómo puede especificar la definición de estado de tarea en función de sus necesidades.

Tiempos de espera de estado de tarea e intervalos de latido

Es aconsejable definir un valor de tiempo de espera y un intervalo de latido para actividades de ejecución prolongada. Para hacer esto se puede especificar los valores de tiempo de espera y latido o configurarlos de forma dinámica.

Ejemplo de notificación de latido y tiempo de espera estático

Cuando se complete HelloWorld, se ejecutará el siguiente estado (que aquí se llama NextState).

Si esta tarea no puede completarse en un plazo de 300 segundos o no envía notificaciones de latido a intervalos de 60 segundos, la tarea se marca como failed.

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

Ejemplo de notificación de latido y tiempo de espera dinámico

En este ejemplo, cuando se complete el AWS Glue trabajo, se ejecutará el siguiente estado.

Si esta tarea no se completa dentro del intervalo establecido de manera dinámica por el trabajo AWS Glue , la tarea se marca como failed.

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

Ejemplos del campo Credentials de estado de tarea

Especificar un rol codificado IAM ARN

El siguiente ejemplo especifica una IAM función de destino que debe asumir la función de ejecución de una máquina de estado para acceder a una función Lambda multicuenta denominada. Echo En este ejemplo, el rol de destino ARN se especifica como un valor codificado.

{
  "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
    }
  }
}

Especificar JSONPath como rol IAM ARN

El siguiente ejemplo especifica un JSONPath valor, que se convertirá en un IAM rol ARN en tiempo de ejecución.

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

Especificar una función intrínseca como IAM rol ARN

En el siguiente ejemplo, se utiliza la función States.Formatintrínseca, que se convierte en un IAM rol ARN en tiempo de ejecución.

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