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 paralelo

O estado Parallel ("Type": "Parallel") pode ser usado para adicionar ramificações separadas de execução em sua máquina de estado.

Além dos campos de estado comuns, os estados Parallel incluem os campos adicionais a seguir.

Um Parallel estado faz AWS Step Functions com que cada ramificação seja executada, começando com o estado nomeado no StartAt campo dessa ramificação, da forma mais simultânea possível, e espere até que todas as ramificações terminem (atinjam um estado terminal) antes de processar o campo do Parallel Next estado.

Exemplo de estado Parallel

{
  "Comment": "Parallel Example.",
  "StartAt": "LookupCustomerInfo",
  "States": {
    "LookupCustomerInfo": {
      "Type": "Parallel",
      "End": true,
      "Branches": [
        {
         "StartAt": "LookupAddress",
         "States": {
           "LookupAddress": {
             "Type": "Task",
             "Resource":
               "arn:aws:lambda:us-east-1:123456789012:function:AddressFinder",
             "End": true
           }
         }
       },
       {
         "StartAt": "LookupPhone",
         "States": {
           "LookupPhone": {
             "Type": "Task",
             "Resource":
               "arn:aws:lambda:us-east-1:123456789012:function:PhoneFinder",
             "End": true
           }
         }
       }
      ]
    }
  }
}

Neste exemplo, as ramificações LookupAddress e LookupPhone são executadas em paralelo. Veja como fica o fluxo de trabalho visual no console do Step Functions.

Toda ramificação deve ser independente. Um estado em uma ramificação de estado Parallel não deve ter um campo Next direcionado a um campo fora da ramificação e qualquer outro estado fora da ramificação não pode mudar para essa ramificação.

Processamento de entrada e saída do estado Parallel

O estado Parallel fornece a cada ramificação uma cópia de seus próprios dados de entrada (que podem ser modificados pelo campo InputPath). Ele gera uma saída que é uma matriz com um elemento para cada ramificação, contendo a saída dessa ramificação. Não há necessidade de que todos os elementos sejam do mesmo tipo. A matriz de saída pode ser inserida nos dados de entrada (e o todo enviado como a saída do estado Parallel) usando um campo ResultPath normalmente (consulte Processamento de entrada e saída).

{
  "Comment": "Parallel Example.",
  "StartAt": "FunWithMath",
  "States": {
    "FunWithMath": {
      "Type": "Parallel",
      "End": true,
      "Branches": [
        {
          "StartAt": "Add",
          "States": {
            "Add": {
              "Type": "Task",
              "Resource": "arn:aws:states:us-east-1:123456789012:activity:Add",
              "End": true
            }
          }
        },
        {
          "StartAt": "Subtract",
          "States": {
            "Subtract": {
              "Type": "Task",
              "Resource": "arn:aws:states:us-east-1:123456789012:activity:Subtract",
              "End": true
            }
          }
        }
      ]
    }
  }
}

Se for atribuído o estado FunWithMath à matriz [3, 2] como entrada, os estados Add e Subtract receberão essa matriz como entrada. A saída das tarefas Add e Subtract seria a soma e a diferença entre os elementos 3 e 2 da matriz, que é 5 e 1, enquanto a saída do estado Parallel seria uma matriz.

[ 5, 1 ]

Como tratar erros

Quando alguma ramificação falha, devido a um erro não tratado ou com a transição para um estado Fail, considera-se que todo o estado Parallel falhou e todas as suas ramificações estão interrompidas. Se o erro não for tratado pelo estado Parallel em si, o Step Functions interromperá a execução com um erro.