Uso del estado Map en modo En línea en flujos de trabajo de Step Functions

De forma predeterminada, los estados Map se ejecutan en modo En línea. En el modo En línea, el estado Map solo acepta una matriz JSON como entrada. Recibe esta matriz de un paso anterior del flujo de trabajo. En este modo, cada iteración del estado Map se ejecuta en el contexto del flujo de trabajo que contiene el estado Map. Step Functions añade el historial de ejecución de estas iteraciones al historial de ejecución del flujo de trabajo principal.

En este modo, el estado Map admite hasta 40 iteraciones simultáneas.

Un estado Map configurado como en línea se conoce como estado Map en línea. Utilice el estado Map en modo En línea si el historial de ejecución del flujo de trabajo no va a superar las 25 000 entradas o si no necesita más de 40 iteraciones simultáneas.

Para ver una introducción al uso del estado Map en línea, consulte el tutorial Repetir acciones con Inline Map.

Conceptos clave de este tema

Campos del estado Map en línea

Para usar el estado Map en línea en los flujos de trabajo, especifique uno o más de estos campos. Estos campos se especifican además de los campos de estado comunes.

Campos obsoletos

Ejemplo de estado Map en línea (JSONPath)

Tenga en cuenta los siguientes datos de entrada para un estado Map que se ejecute en modo En línea.

{
  "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 }
    ]
  }
}

Dada la entrada anterior, el estado Map del siguiente ejemplo invocará una función AWS Lambda denominada ship-val una vez por cada elemento de la matriz en el 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 iteración del estado Map enviará un elemento de la matriz. seleccionado mediante el campo ItemsPath, como entrada para la función de Lambda ship-val. Los siguientes valores son un ejemplo de la entrada que el estado Map envía a una invocación de la función de Lambda:

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

Una vez completada, la salida del estado Map es una matriz JSON en la que cada elemento es la salida de una iteración. En este caso, esta matriz contiene la salida de la función de Lambda ship-val.

Ejemplo de estado Map en línea con ItemSelector

Supongamos que la función de Lambda ship-val del ejemplo anterior también necesita información sobre el transportista del envío. Esta información se añade a los elementos de la matriz para cada iteración. Puede incluir información de la entrada, junto con información específica de la iteración actual del estado Map. Observe el campo ItemSelector del siguiente ejemplo:

"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
}

El bloque ItemSelector reemplaza la entrada a las iteraciones por un nodo JSON. Este nodo contiene tanto los datos del elemento actual del objeto Context como la información del transportista del campo delivery-partner de la entrada del estado Map. A continuación, se muestra un ejemplo de entrada en una sola iteración. El estado Map pasa esta entrada a una invocación de la función de Lambda ship-val.

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

En el ejemplo anterior del estado Map en línea, el campo ResultPath produce una salida en el mismo formato que la entrada. No obstante, sobrescribe el campo detail.shipped con una matriz en la que cada elemento es la salida de la invocación de Lambda ship-val de cada iteración.

Para obtener más información sobre el uso del estado Map en línea y sus campos, consulte lo siguiente.

Procesamiento de entrada y salida del estado Map en línea

Para un estado Map determinado, InputPath selecciona un subconjunto de la entrada del estado.

La entrada de un estado Map debe incluir una matriz JSON. El estado Map ejecuta la sección ItemProcessor una vez para cada elemento de la matriz. Si especifica el campo ItemsPath, el estado Map selecciona en qué parte de la entrada se busca la matriz sobre la que se va a iterar. Si no se especifica, el valor de ItemsPath es $ y la sección ItemProcessor espera que la matriz sea la única entrada. Si especifica el campo ItemsPath, su valor debe ser una ruta de referencia. El estado Map aplica esta ruta a la entrada efectiva después de aplicar la InputPath. La ItemsPath debe identificar un campo cuyo valor sea una matriz JSON.

La entrada de cada iteración, de forma predeterminada, es un único elemento del campo de matriz identificado por el valor ItemsPath. Puede anular este valor con el campo ItemSelector (Map).

Una vez completada, la salida del estado Map es una matriz JSON en la que cada elemento es la salida de una iteración.

Para obtener más información acerca de las entradas y salidas del estado Map en línea, consulte lo siguiente: