Invocación asincrónica - AWS Lambda

Invocación asincrónica

Varios servicios de AWS, como Amazon Simple Storage Service (Amazon S3) y Amazon Simple Notification Service (Amazon SNS), invocan funciones de forma ansíncrona para procesar eventos. Cuando se invoca una función de forma asíncrona, no se espera una respuesta del código de función. Se entrega el evento a Lambda, y Lambda se ocupa del resto. Puede configurar la forma en que Lambda maneja los errores y puede enviar registros de invocación a un recurso descendente para encadenar los componentes de la aplicación.

El siguiente diagrama muestra los clientes que invocan una función Lambda de forma asíncrona. Lambda pone en cola los eventos antes de enviarlos a la función.


      Los clientes invocan una función de forma asíncrona. Lambda pone en cola los eventos antes de enviarlos a la función.

Para la invocación asíncrona, Lambda coloca el evento en una cola y devuelve una respuesta de “proceso realizado con éxito” sin información adicional. Un proceso independiente lee eventos de la cola y los envía a la función. Para invocar una función de forma asíncrona, establezca el parámetro de tipo de invocación en Event.

aws lambda invoke --function-name my-function --invocation-type Event --payload '{ "key": "value" }' response.json

Debería ver los siguientes datos de salida:

{ "StatusCode": 202 }

El archivo de salida (response.json) no contiene ninguna información, pero se crea al ejecutar este comando. Si Lambda no puede añadir el caso a la cola, el mensaje de error aparece en la salida del comando.

Lambda administra la cola de eventos asincrónica de la función y trata de reintentarlo en caso de errores. Si la función devuelve un error, Lambda intenta ejecutarla dos veces más, con una espera de un minuto entre los dos primeros intentos y dos minutos entre el segundo y el tercero. Los errores de la función incluyen errores devueltos por el código de la función y los errores devueltos por el tiempo de ejecución de la función, como, por ejemplo, los tiempos de espera.


      Lambda registra cada intento en un subsegmento.

Si la función no tiene disponible suficiente simultaneidad para procesar todos los eventos, se limitan las solicitudes adicionales. Para limitar errores (429) y errores del sistema (serie 500), Lambda devuelve el evento a la cola e intenta ejecutar la función de nuevo durante un máximo de 6 horas. El intervalo de reintento aumenta exponencialmente desde 1 segundo después del primer intento hasta un máximo de 5 minutos. Sin embargo, podría tardar más si se realiza una copia de seguridad de la cola. Lambda también reduce la velocidad a la que lee eventos de la cola.

El siguiente ejemplo muestra un evento que se añadió correctamente a la cola, pero que aún está pendiente una hora después debido a la restricción.


      Las solicitudes limitadas aparecen como pendientes en AWS X-Ray.

Aunque la función no devuelva un error, es posible que reciba el mismo evento de Lambda varias veces, ya que la propia cola ofrece consistencia final. Si la función no es capaz de gestionar los eventos entrantes, podrían también eliminarse de la cola sin que se envíen a la función. Asegúrese de que el código de la función gestione sin problemas eventos duplicados y de que tenga simultaneidad suficiente disponible para gestionar todas las invocaciones.

Cuando se realiza una copia de seguridad de la cola, es posible que los nuevos eventos se agoten antes de que Lambda pueda enviarlos a la función. Cuando un evento caduca o todos los intentos de procesamiento fallan, Lambda lo descarga. Puede configurar la gestión de errores de una función para reducir el número de reintentos que realiza Lambda o para descartar eventos no procesados más rápidamente.

También puede configurar Lambda para que envíe un registro de invocación a otro servicio. Lambda admite los siguientes destinos para la invocación asincrónica.

  • Amazon SQS: una cola de SQS estándar.

  • Amazon SNS: un tema de SNS.

  • AWS Lambda: una función Lambda.

  • Amazon EventBridge: un bus de eventos de EventBridge.

El registro de invocación contiene detalles sobre la solicitud y la respuesta en formato JSON. Puede configurar destinos independientes en eventos que se procesan con éxito, y eventos que fallan todos los intentos de procesamiento. También puede configurar una cola de SQS o un tema de SNS como una cola de mensajes fallidos para eventos descartados. En las colas de mensajes fallidos, Lambda solo envía el contenido del evento, sin detalles sobre la respuesta.

Configuración de la gestión de errores para la invocación asincrónica

Utilice la consola de Lambda para configurar los ajustes de gestión de errores en una función, una versión o un alias.

Para configurar la gestión de errores

  1. Abra la Página de funciones en la consola de Lambda.

  2. Elija una función.

  3. Elija Configuración y, a continuación, elija Invocación asíncrona.

  4. En Asynchronous invocation (Invocación asincrónica), elija Edit (Editar).

  5. Configure los siguientes ajustes.

    • Maximum age of event (Antigüedad máxima del evento): El período máximo de tiempo durante el que Lambda retiene un evento en la cola de evento asincrónico, hasta 6 horas.

    • Retry attempts (Número de reintentos): número de reintentos que Lambda realiza cuando la función devuelve un error, entre 0 y 2.

  6. Seleccione Save.

Cuando un evento de invocación supera la antigüedad máxima o no supera ningún reintento, Lambda lo descarta. Para conservar una copia de eventos descartados, configure un destino de eventos fallidos.

Configuración de destinos para invocación asincrónica

Para enviar registros de invocaciones asincrónicas a otro servicio, añada un destino a su función. Puede configurar destinos independientes para eventos que no superan el procesamiento y para eventos que se procesan correctamente. Al igual que con los ajustes de gestión de errores, puede configurar los destinos en una función, versión o alias.

El siguiente ejemplo muestra una función que está procesando invocaciones asincrónicas. Cuando la función devuelve una respuesta correcta o sale sin lanzar un error, Lambda envía un registro de la invocación a un bus de eventos EventBridge. Cuando un evento falla todos los intentos de procesamiento, Lambda envía un registro de invocación a una cola de Amazon SQS.


        Lambda envía registros de invocación a un destino de bus de evento o a una cola, dependiendo del resultado.

Para enviar eventos a un destino, su función necesita permisos adicionales. Añada una política con los permisos necesarios al rol de ejecución de la función. Cada servicio de destino requiere un permiso diferente, como se indica a continuación:

Añada destinos a su función en la visualización de funciones de la consola de Lambda.

Para configurar un destino para registros de invocación asincrónicos

  1. Abra la Página de funciones en la consola de Lambda.

  2. Elija una función.

  3. En Function overview (Descripción general de la función), elija Add destination (Agregar destino).

  4. En Source (Origen), elija Asynchronous invocation (Invocación asincrónica).

  5. En Condition (Condición) elija una de las siguientes opciones:

    • On failure (En caso de error): enviar un registro cuando el evento no supera los intentos de procesamiento o supera la antigüedad máxima.

    • On success (Si es correcto): enviar un registro cuando la función procesa correctamente una invocación asincrónica.

  6. En Destination type (Tipo de destino), elija el tipo de recurso que recibe el registro de invocación.

  7. En Destination (Destino), elija un recurso.

  8. Seleccione Save.

Cuando una invocación coincide con la condición, Lambda envía un documento JSON con detalles sobre la invocación al destino. El ejemplo siguiente muestra un registro de invocación para un evento que ha fallado tres intentos de procesamiento debido a un error de función.

ejemplo Registro de invocación

{ "version": "1.0", "timestamp": "2019-11-14T18:16:05.568Z", "requestContext": { "requestId": "e4b46cbf-b738-xmpl-8880-a18cdf61200e", "functionArn": "arn:aws:lambda:us-east-2:123456789012:function:my-function:$LATEST", "condition": "RetriesExhausted", "approximateInvokeCount": 3 }, "requestPayload": { "ORDER_IDS": [ "9e07af03-ce31-4ff3-xmpl-36dce652cb4f", "637de236-e7b2-464e-xmpl-baf57f86bb53", "a81ddca6-2c35-45c7-xmpl-c3a03a31ed15" ] }, "responseContext": { "statusCode": 200, "executedVersion": "$LATEST", "functionError": "Unhandled" }, "responsePayload": { "errorMessage": "RequestId: e4b46cbf-b738-xmpl-8880-a18cdf61200e Process exited before completing request" } }

El registro de invocación contiene detalles sobre el evento, la respuesta y el motivo por el que se ha enviado el registro.

API de configuración de invocación asincrónica

Para administrar la configuración de invocación asincrónica con la CLI o el SDK de AWS, utilice las siguientes operaciones de la API.

Para configurar la invocación asincrónica con la CLI de AWS, utilice el comando put-function-event-invoke-config. En el ejemplo siguiente se configura una función con una antigüedad máxima de evento de 1 hora y sin reintentos.

aws lambda put-function-event-invoke-config --function-name error \ --maximum-event-age-in-seconds 3600 --maximum-retry-attempts 0

Debería ver los siguientes datos de salida:

{ "LastModified": 1573686021.479, "FunctionArn": "arn:aws:lambda:us-east-2:123456789012:function:error:$LATEST", "MaximumRetryAttempts": 0, "MaximumEventAgeInSeconds": 3600, "DestinationConfig": { "OnSuccess": {}, "OnFailure": {} } }

El comando put-function-event-invoke-config sobrescribe cualquier configuración existente en la función, versión o alias. Para configurar una opción sin reiniciar otras, utilice update-function-event-invoke-config. En el ejemplo siguiente se configura Lambda para enviar un registro a una cola de SQS llamada destination cuando no se puede procesar un evento.

aws lambda update-function-event-invoke-config --function-name error \ --destination-config '{"OnFailure":{"Destination": "arn:aws:sqs:us-east-2:123456789012:destination"}}'

Debería ver los siguientes datos de salida:

{ "LastModified": 1573687896.493, "FunctionArn": "arn:aws:lambda:us-east-2:123456789012:function:error:$LATEST", "MaximumRetryAttempts": 0, "MaximumEventAgeInSeconds": 3600, "DestinationConfig": { "OnSuccess": {}, "OnFailure": { "Destination": "arn:aws:sqs:us-east-2:123456789012:destination" } } }

Colas de mensajes fallidos de funciones de AWS Lambda

Como alternativa a un destino en caso de fallo, puede configurar su función con una cola de mensajes fallidos para guardar eventos descartados para su posterior procesamiento. Una cola de mensajes fallidos actúa igual que un destino en caso de error, ya que se utiliza cuando un evento falla todos los intentos de procesamiento o caduca sin ser procesado. Sin embargo, una cola de mensajes fallidos forma parte de la configuración específica de la versión de una función, por lo que se bloquea cuando se publica una versión. Los destinos en caso de error también admiten destinos adicionales e incluyen detalles sobre la respuesta de la función en el registro de invocación.

Si no se dispone de una cola o tema, debe crearse. Elija el tipo de destino que coincida con su caso de uso.

Para enviar eventos a una cola o tema, la función necesita permisos adicionales. Añada una política con los permisos necesarios al rol de ejecución de la función.

Si la cola o el tema de destino están cifrados con una clave administrada por el cliente, el rol de ejecución también debe ser un usuario en la política basada en recursos de la clave.

Después de crear el destino y actualizar el rol de ejecución de la función, añada la cola de mensajes fallidos a la función. Puede configurar varias funciones para enviar eventos al mismo destino.

Para configurar una cola de mensajes fallidos

  1. Abra la Página de funciones en la consola de Lambda.

  2. Elija una función.

  3. Elija Configuración y, a continuación, elija Invocación asíncrona.

  4. En Asynchronous invocation (Invocación asincrónica), elija Edit (Editar).

  5. Establezca DLQ resource (Recurso de DLQ) en Amazon SQS o Amazon SNS.

  6. Elija la cola o el tema de destino.

  7. Seleccione Save (Guardar).

Para configurar una cola de mensajes fallidos con la AWS CLI, utilice el comando update-function-configuration.

aws lambda update-function-configuration --function-name my-function \ --dead-letter-config TargetArn=arn:aws:sns:us-east-2:123456789012:my-topic

Lambda envía el evento a la cola de mensajes fallidos tal y como está, con información adicional en atributos. Puede utilizar esta información para identificar el error que la función devuelve o correlacionar el evento con los registros o un rastro de AWS X-Ray.

Atributos de mensajes de cola de mensajes fallidos

  • RequestID (cadena): el ID de la solicitud de invocación. Los ID de las solicitudes aparecen en los registros de la función. También puede usar el SDK de X-Ray para registrar el ID de solicitud en un atributo del rastro. A continuación, puede buscar rastros por ID de solicitud en la consola de X-Ray. Consulte el ejemplo de procesador de errores para ver un ejemplo.

  • ErrorCode (número): el código de estado de HTTP.

  • ErrorMessage (cadena): el primer 1 KB del mensaje de error.


      Atributos de eventos de cola de mensajes fallidos en la consola de Amazon SQS.

Si Lambda no puede enviar un mensaje a la cola de mensajes fallidos, elimina el evento y emite la métrica DeadLetterErrors. Esto puede ocurrir debido a la falta de permisos o si el tamaño total del mensaje supera el límite de la cola o tema de destino. Por ejemplo, si una notificación de Amazon SNS cuyo cuerpo tiene cerca de 256 KB activa una función que genera un error, los datos adicionales del evento añadidos por Amazon SNS, junto con los atributos añadidos por Lambda, pueden hacer que el mensaje supere el tamaño máximo permitido en la cola de mensajes fallidos.

Si está utilizando Amazon SQS como origen de eventos, configure una cola de mensajes fallidos en la propia cola de Amazon SQS y no en la función de Lambda. Para obtener más información, consulte Uso de AWS Lambda con Amazon SQS.