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

A Amazon States Language representa tarefas definindo o tipo de um estado como Task e fornecendo à tarefa o nome do recurso da Amazon (ARN) da atividade, a função do Lambda ou o endpoint da API HTTPS.

Invocar uma função com argumentos JSONata

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

Observe o uso de expressões JSONata para consultar os 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>:account-id:function:priceWatcher:$LATEST"
  },
  "Assign": {
    "currentPrice": "{% $states.result.Payload.current_price %}"
  }
}

Invocar uma função com parâmetros JSONPath

A definição de estado de tarefa (JSONPath) a seguir invoca uma função do Lambda chamada HelloFunction.

"Lambda Invoke": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:region:account-id: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 tarefa, exceto o 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 Tarefa, substitua o texto em itálico na seguinte sintaxe pelas informações específicas do recurso da AWS.

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.

Os ARNS de Resource de atividade usam a sintaxe a seguir.

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 do 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.

A forma do campo Resource da função do Lambda varia conforme o tipo de integração.

Para uma integração padrão do AWS SDK com uma função do Lambda, o campo Resource conterá o seguinte valor:

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

Recomendamos usar a integração otimizada para suas funções do Lambda, usando o seguinte valor para o campo Resource:

"arn:aws:states:::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 usando JSONata.

"Optimized call to Lambda function (JSONata)": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Output": "{% $states.result.Payload %}",
      "Arguments": {
        "FunctionName": "arn:aws:lambda:region:account-id:function:HelloWorld:$LATEST",
        "Payload": {
          "key": "{% $states.input.myKey %}"
        }
      },
  "Next": "NextState"
}

Um AWS service (Serviço da AWS) compatível

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.

Os ARNS de Resource do serviço conectado usam a sintaxe a seguir.

arn:partition:states:region:account-id: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:region: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 trabalho AWS Glue 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
    }
  }
}

Especificar o JSONPath como ARN do perfil do IAM

O exemplo a seguir especifica um valor JSONPath, que será resolvido em um ARN do perfil do IAM em runtime.

{
  "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)"
      },
      ...
    }
  }
}