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 de tarefa do fluxo de trabalho

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 AWS Lambda função, integrando-se a outras suportadas Serviços da AWS ou invocando uma API HTTPS, como o Stripe.

A 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 da API HTTPS.

Invocar uma função com argumentos JSONata

A definição de estado da tarefa a seguir (JSONata) invoca uma função Lambda chamada. priceWatcher

Observe o uso de JSONata expressões para consultar dados de entrada para usar em Argumentos e o resultado da tarefa no campo de atribuição.

"Get Current Price": {
  "Type": "Task",
  "QueryLanguage" : "JSONata",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Next": "Check Price",
  "Arguments": {
    "Payload": {
    "product": "{% $states.context.Execution.Input.product %}"
    },
    "FunctionName": "arn:aws:lambda:<region>:123456789012:function:priceWatcher:$LATEST"
  },
  "Assign": {
    "currentPrice": "{% $states.result.Payload.current_price %}"
  }
}

Invocar uma função com parâmetros JSONPath

A definição de estado da tarefa a seguir (JSONPath) invoca uma função 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 seu ARN no campo Resource da definição do estado Tarefa. O exemplo a seguir mostra a sintaxe do campo Resource. Todos os tipos de tarefas, exceto aquele que invoca uma API HTTPS, usam a sintaxe a seguir. Para obter informações sobre a sintaxe da tarefa HTTP, consulte Chame HTTPS 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 pelas informações específicas do AWS 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 o. AWS Lambda Para especificar uma função do Lambda, use o ARN da função do Lambda no campo Resource.

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

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 integração do AWS SDK 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)

Ao fazer referência a um recurso conectado, o Step Functions chama diretamente as ações de API de um serviço compatível. 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 trabalho for concluído, o próximo estado será executado.

Se essa tarefa não for concluída dentro do intervalo definido dinamicamente pelo trabalho AWS Glue , a tarefa será marcada como failed.

"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

Especificar o ARN do perfil do IAM com codificação rígida

O exemplo a seguir especifica um perfil do IAM de destino que o perfil do IAM de execução de uma máquina de estado deve assumir para acessar uma função do Lambda entre contas chamada Echo. Neste exemplo, o ARN do perfil de destino é especificado como um valor com codificação rígida.

{
  "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 ARN da função do IAM

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

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

Especificar uma função intrínseca como ARN do perfil do IAM

O exemplo a seguir usa a função intrínseca States.Format, que será resolvida em um ARN do perfil do IAM em runtime.

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