Usar o estado de mapa no modo inline em fluxos de trabalho do Step Functions

Por padrão, os estados Map são executados no modo inline. No modo inline, o estado Mapa aceita somente uma matriz JSON como entrada. Ele recebe essa matriz de uma etapa anterior no fluxo de trabalho. Nesse modo, cada iteração do estado Map é executada no contexto do fluxo de trabalho que contém o estado Map. O Step Functions adiciona o histórico de execução dessas iterações ao histórico de execuções do fluxo de trabalho principal.

Nesse modo, o estado Map oferece suporte para até 40 iterações simultâneas.

Um estado Map definido como Inline é conhecido como estado Mapa inline. Use o estado Map no modo Em linha se o histórico de execução do fluxo de trabalho não exceder 25 mil entradas ou se você não precisar de mais de 40 iterações simultâneas.

Para obter uma introdução ao uso do estado Mapa inline, consulte o tutorial Repetir ações com o mapa inline.

Principais conceitos neste tópico

Campos do estado Mapa inline

Para usar o estado Mapa inline em fluxos de trabalho, especifique um ou mais dos campos a seguir. Você especifica esses campos além dos campos de estado comuns.

Campos descontinuados

Exemplo de estado de mapa inline (JSONPath)

Considere os seguintes dados de entrada para um estado Map no modo inline.

{
  "ship-date": "2016-03-14T01:59:00Z",
  "detail": {
    "delivery-partner": "UQS",
    "shipped": [
      { "prod": "R31", "dest-code": 9511, "quantity": 1344 },
      { "prod": "S39", "dest-code": 9511, "quantity": 40 },
      { "prod": "R31", "dest-code": 9833, "quantity": 12 },
      { "prod": "R40", "dest-code": 9860, "quantity": 887 },
      { "prod": "R40", "dest-code": 9511, "quantity": 1220 }
    ]
  }
}

Considerando a entrada anterior, o estado Map no exemplo a seguir invocará uma função do AWS Lambda chamada ship-val uma vez para cada item da matriz no campo shipped.

"Validate All": {
    "Type": "Map",
    "InputPath": "$.detail",
    "ItemProcessor": {
        "ProcessorConfig": {
            "Mode": "INLINE"
        },
        "StartAt": "Validate",
        "States": {
            "Validate": {
                "Type": "Task",
                "Resource": "arn:aws:states:::lambda:invoke",
                "OutputPath": "$.Payload",
                "Parameters": {
                    "FunctionName": "arn:aws:lambda:us-east-2:account-id:function:ship-val:$LATEST"
                },
                "End": true
            }
        }
    },
    "End": true,
    "ResultPath": "$.detail.shipped",
    "ItemsPath": "$.shipped"
}

Cada iteração do estado Map enviará um item na matriz, selecionada com o campo ItemsPath como entrada para a função do Lambda ship-val. Os valores a seguir são um exemplo de entrada que o estado Map envia para uma invocação da função do Lambda:

{
  "prod": "R31",
  "dest-code": 9511,
  "quantity": 1344
}

Quando concluída, a saída do estado Map é uma matriz JSON, onde cada item é a saída de uma iteração. Nesse caso, essa matriz contém a saída da função do Lambda ship-val.

Exemplo de estado Mapa inline com ItemSelector.

Vamos supor que a função do Lambda ship-val no exemplo anterior também precise de informações sobre a transportadora da remessa. Essas informações são adicionadas aos itens na matriz para cada iteração. Você pode incluir informações da entrada, juntamente com informações específicas à iteração atual do estado Map. Observe o campo ItemSelector no exemplo a seguir.

"Validate-All": {
  "Type": "Map",
  "InputPath": "$.detail",
  "ItemsPath": "$.shipped",
  "MaxConcurrency": 0,
  "ResultPath": "$.detail.shipped",
  "ItemSelector": {
    "parcel.$": "$$.Map.Item.Value",
    "courier.$": "$.delivery-partner"
  },
  "ItemProcessor": {
    "StartAt": "Validate",
    "States": {
      "Validate": {
        "Type": "Task",
	"Resource": "arn:aws:lambda:region:account-id:function:ship-val",
        "End": true
      }
    }
  },
  "End": true
}

O bloco ItemSelector substitui a entrada das iterações por um nó JSON. Esse nó contém os dados do item atual do objeto de contexto e as informações da transportadora do campo delivery-partner da entrada do estado Map. O exemplo a seguir é um entrada para uma única iteração. O estado Map transmite essa entrada para uma invocação da função do Lambda ship-val.

{
  "parcel": {
    "prod": "R31",
    "dest-code": 9511,
    "quantity": 1344
   },
   "courier": "UQS"
}

No exemplo anterior do estado Mapa inline, o campo ResultPath produz uma saída no mesmo formato da entrada. No entanto, ele substitui o campo detail.shipped por uma matriz na qual cada elemento é a saída da invocação do Lambda ship-val de cada iteração.

Para ver mais informações sobre como usar o estado Mapa inline e seus campos, consulte o seguinte:

Processamento de entrada e saída do estado Map inline.

Para um determinado estado Map, o InputPath seleciona um subconjunto da entrada do estado.

A entrada de um estado Map deve incluir uma matriz JSON. O estado Map executa a seção ItemProcessor uma vez para cada item na matriz. Se você especificar o campo ItemsPath, o estado Map selecionará onde na entrada encontrar a matriz sobre a qual iterar. Se não for especificado, o valor de ItemsPath será $, e a seção ItemProcessor esperará que a matriz seja a única entrada. Se você especificar o campo ItemsPath, seu valor deverá ser um caminho de referência. O estado Map aplica esse caminho à entrada efetiva depois de aplicar o InputPath. O ItemsPath deve identificar um campo cujo valor seja uma matriz JSON.

A entrada para cada iteração, por padrão, é um único elemento do campo de matriz identificado pelo valor ItemsPath. Você pode substituir esse valor pelo campo ItemSelector (mapa).

Quando concluída, a saída do estado Map é uma matriz JSON, onde cada item é a saída de uma iteração.

Para ver mais informações sobre entradas e saídas do estado Mapa inline, consulte: