As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Estado do fluxo de trabalho da tarefa

Um estado Task ("Type": "Task") representa uma unidade de trabalho específica executada por uma máquina de estado. Uma tarefa executa o trabalho usando uma atividade ou um AWS Lambda função, por meio da integração com outros suportados Serviços da AWS, ou invocando um terceiroAPI, como o Stripe.

O Amazon States Language representa tarefas definindo o tipo de estado Task e fornecendo à tarefa o Amazon Resource Name (ARN) da atividade, da função Lambda ou do endpoint de terceirosAPI. A seguinte definição de estado Tarefa invoca uma função do Lambda chamada 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 tarefa

O Step Functions é compatível com os seguintes tipos de tarefa que você pode especificar em uma definição de estado Tarefa.

Você especifica um tipo de tarefa fornecendo-o ARN no Resource campo de uma definição de estado da tarefa. O exemplo a seguir mostra a sintaxe do campo Resource. Todos os tipos de tarefas, exceto aquele que invoca um terceiroAPI, usam a sintaxe a seguir. Para obter informações sobre a sintaxe da HTTP tarefa, consulteChame terceiros APIs nos fluxos de trabalho do Step Functions.

Na definição do estado da tarefa, substitua o texto em itálico na sintaxe a seguir pelo AWS informações específicas do recurso.

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

A lista a seguir explica os componentes individuais dessa sintaxe.

As seções a seguir oferecem mais detalhes sobre cada tipo de tarefa.

Atividade

As atividades representam operadores (processos ou threads), implementados e hospedados por você, que executam uma tarefa específica. Eles oferecem suporte apenas de fluxos de trabalho padrão, não de expressos.

A atividade Resource ARNs usa a seguinte sintaxe.

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

Para obter mais informações sobre a criação de uma atividade e a implementação de operadores, consulte Atividades.

Funções do Lambda

As tarefas Lambda executam uma função usando AWS Lambda. Para especificar uma função Lambda, use a função ARN Lambda no campo. Resource

Dependendo do tipo de integração (integração otimizada ou AWS SDKintegração) que você usa para especificar uma função Lambda, a sintaxe do campo da sua função Lambda varia. Resource

A seguinte sintaxe do campo Resource é um exemplo de uma integração otimizada com uma função do Lambda.

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

A sintaxe de Resource campo a seguir é um exemplo de AWS SDKintegração com uma função Lambda.

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

A definição de estado Task a seguir mostra um exemplo de uma integração otimizada com uma função do Lambda chamada 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"
}

Depois que a função Lambda especificada no Resource campo for concluída, sua saída será enviada para o estado identificado no Next campo (” “). NextState

Um suportado AWS service (Serviço da AWS)

Quando você faz referência a um recurso conectado, o Step Functions chama diretamente as API ações de um serviço suportado. Especifique o serviço e a ação no campo Resource.

O serviço conectado Resource ARNs usa a seguinte sintaxe.

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

Por exemplo:

{
 "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 do estado Tarefa

Além dos campos de estado comuns, os estados Task têm os campos a seguir.

Um estado Task deverá definir o campo End como true se o estado encerrar a execução, ou deverá fornecer um estado no campo Next que será executado quando o estado Task for concluído.

Exemplos de definição de estado Tarefa

Os exemplos a seguir mostram como especificar a definição do estado Tarefa com base na sua necessidade.

Tempos limite e intervalos de pulsação do estado Tarefa

É recomendável definir um valor de tempo limite e um intervalo de pulsação para atividades de longa duração. Isso pode ser feito especificando os valores de tempo limite e pulsação ou definindo-os dinamicamente.

Exemplo de tempo limite estático e notificação de pulsação

Quando HelloWorld for concluída, o próximo estado (chamado aqui de NextState) será executado.

Se essa tarefa não for concluída em 300 segundos ou não enviar notificações de pulsação em intervalos de 60 segundos, ela será marcada como failed.

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

Exemplo de tempo limite de tarefa dinâmica e notificação de pulsação

Neste exemplo, quando o AWS Glue o trabalho é concluído, o próximo estado será executado.

Se essa tarefa não for concluída dentro do intervalo definido dinamicamente pelo AWS Glue trabalho, a tarefa é marcada comofailed.

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

Exemplos do campo Credenciais do estado Tarefa

Especificando uma função IAM codificada ARN

O exemplo a seguir especifica uma função de destino que a IAM função de execução de uma máquina de estado deve assumir para acessar uma função Lambda entre contas chamada. Echo Neste exemplo, a função de destino ARN é especificada como um 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
    }
  }
}

Especificando JSONPath como função IAM ARN

O exemplo a seguir especifica um JSONPath valor, que será resolvido em uma IAM função ARN em tempo de execução.

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

Especificando uma função intrínseca como função IAM ARN

O exemplo a seguir usa a função States.Formatintrínseca, que se transforma em uma IAM função ARN em tempo de execução.

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