Invocación de funciones duraderas de Lambda

Las funciones duraderas de Lambda se pueden invocar con los mismos métodos que las funciones predeterminadas de Lambda, pero con consideraciones importantes para las ejecuciones de larga duración. En esta sección, se describen los patrones de invocación, la administración de ejecuciones y las prácticas recomendadas para las funciones duraderas.

Límites de invocaciones sincrónicas

Las invocaciones sincrónicas de funciones de Lambda duraderas están limitadas a 15 minutos, igual que las funciones de Lambda predeterminadas. Si la función duradera necesita ejecutarse durante más de 15 minutos, debe invocarse de forma asíncrona.

Cuándo utilizar la invocación sincrónica: utilícela para funciones duraderas que se completen en 15 minutos y cuando necesite resultados inmediatos, como flujos de trabajo de aprobación rápidos o tareas breves de procesamiento de datos.

Invocación asíncrona para flujos de trabajo de larga duración

Para funciones duraderas que pueden durar más de 15 minutos, utilice la invocación asíncrona. Esto permite que la función siga ejecutándose mientras el cliente recibe un reconocimiento inmediato.

TypeScript

import { LambdaClient, InvokeCommand } from "@aws-sdk/client-lambda";

const client = new LambdaClient({});

// Asynchronous invocation
const command = new InvokeCommand({
  FunctionName: "my-durable-function",
  InvocationType: "Event", // Asynchronous
  Payload: JSON.stringify({ orderId: "12345" })
});

await client.send(command);
          

Python

import boto3
import json

client = boto3.client('lambda')

# Asynchronous invocation
response = client.invoke(
    FunctionName='my-durable-function',
    InvocationType='Event',  # Asynchronous
    Payload=json.dumps({'order_id': '12345'})
)
          

API de administración de ejecución

Lambda proporciona API para administrar y supervisar las ejecuciones de funciones duraderas, lo que incluye enumerar las ejecuciones, obtener el estado de las ejecuciones y detener las ejecuciones en ejecución.

TypeScript

// Get execution status
const statusCommand = new InvokeCommand({
  FunctionName: "my-durable-function",
  InvocationType: "RequestResponse",
  Payload: JSON.stringify({ 
    action: "getStatus", 
    executionId: "exec-123" 
  })
});

const result = await client.send(statusCommand);
          

Python

# Get execution status
response = client.invoke(
    FunctionName='my-durable-function',
    InvocationType='RequestResponse',
    Payload=json.dumps({
        'action': 'get_status',
        'execution_id': 'exec-123'
    })
)