Funzioni Lambda di Python

Il generatore di funzioni Lambda Python offre la possibilità di aggiungere una funzione lambda a un progetto Python esistente.

Questo generatore crea un nuovo handler per funzioni lambda Python con la configurazione dell’infrastruttura AWS CDK. Il backend generato utilizza AWS Lambda per il deployment serverless, con opzionale type-safety tramite il Parser di AWS Lambda Powertools. Configura AWS Lambda Powertools per l’osservabilità, inclusi logging, tracciamento AWS X-Ray e metriche CloudWatch.

Utilizzo

Genera una funzione Lambda

Puoi generare una nuova funzione Lambda in due modi:

VSCode

1. Installa il Nx Console VSCode Plugin se non l'hai già fatto
2. Apri la console Nx in VSCode
3. Clicca su Generate (UI) nella sezione "Common Nx Commands"
4. Cerca @aws/nx-plugin - py#lambda-function
5. Compila i parametri richiesti
6. Clicca su Generate

CLI

pnpm

pnpm nx g @aws/nx-plugin:py#lambda-function

yarn

yarn nx g @aws/nx-plugin:py#lambda-function

npm

npx nx g @aws/nx-plugin:py#lambda-function

bun

bunx nx g @aws/nx-plugin:py#lambda-function

Puoi anche eseguire una prova per vedere quali file verrebbero modificati

pnpm

pnpm nx g @aws/nx-plugin:py#lambda-function --dry-run

yarn

yarn nx g @aws/nx-plugin:py#lambda-function --dry-run

npm

npx nx g @aws/nx-plugin:py#lambda-function --dry-run

bun

bunx nx g @aws/nx-plugin:py#lambda-function --dry-run

Opzioni

Parametro	Tipo	Predefinito	Descrizione
project Obbligatorio	string	-	The project to add the lambda function to
functionName Obbligatorio	string	-	The name of the function to add
functionPath	string	-	The path within the project source directory to add the function to
eventSource	string	Any	Optional event source model to use for the lambda function

Output del generatore

Il generatore aggiungerà i seguenti file al tuo progetto:

• Directory<module-name>

  • <lambda-function>.py Implementazione della funzione

Il generatore creerà anche costrutti CDK utilizzabili per il deployment della funzione, residenti nella directory packages/common/constructs.

Se viene fornita l’opzione functionPath, il generatore aggiungerà i file necessari al percorso specificato:

• Directory<module-name>

  • Directory<custom-path>

    • <function-name>.py Implementazione della funzione

Implementazione della funzione

L’implementazione principale della funzione si trova in <function-name>.py. Ecco un esempio:

import os

from aws_lambda_powertools import Logger, Metrics, Tracer
from aws_lambda_powertools.metrics import MetricUnit
from aws_lambda_powertools.utilities.parser import event_parser
from aws_lambda_powertools.utilities.parser.models import EventBridgeModel
from aws_lambda_powertools.utilities.typing import LambdaContext

os.environ["POWERTOOLS_METRICS_NAMESPACE"] = "Foo"
os.environ["POWERTOOLS_SERVICE_NAME"] = "Foo"

logger: Logger = Logger()
metrics: Metrics = Metrics()
tracer: Tracer = Tracer()

@tracer.capture_lambda_handler
@metrics.log_metrics
@event_parser(model=EventBridgeModel)
def lambda_handler(event: EventBridgeModel, context: LambdaContext):
    logger.info("Received event", extra={"event": event.model_dump() })
    metrics.add_metric(name="InvocationCount", unit=MetricUnit.Count, value=1)

    try:
        # TODO: Implement
        metrics.add_metric(name="SuccessCount", unit=MetricUnit.Count, value=1)
        # TODO: Implement success response if required
    except Exception as e:
        logger.exception(e)
        metrics.add_metric(name="ErrorCount", unit=MetricUnit.Count, value=1)
        # TODO: Implement error response if required

Il generatore configura automaticamente diverse funzionalità:

1. Integrazione di AWS Lambda Powertools per l’osservabilità
2. Raccolta delle metriche
3. Type-safety tramite @event_parser

Osservabilità con AWS Lambda Powertools

Logging

Il generatore configura il logging strutturato utilizzando AWS Lambda Powertools.

def lambda_handler(event: EventBridgeModel, context: LambdaContext):
    logger.info("Received event", extra={"event": event.model_dump()})

Consiglio

Si consiglia di impostare un correlation ID per tutte le richieste uniche per facilitare il debug e il monitoraggio. Consulta la documentazione di aws powertools logger per le best practice sui correlation ID.

Il logger include automaticamente:

• Richieste di eventi
• Informazioni sul contesto Lambda
• Indicatori di cold start

Tracciamento

Il tracciamento AWS X-Ray viene configurato automaticamente. Puoi aggiungere sottosegmenti personalizzati:

def lambda_handler(event: EventBridgeModel, context: LambdaContext):
    # Crea un nuovo sottosegmento
    with tracer.provider.in_subsegment("function-subsegment"):
        # Logica personalizzata
        return ....

Metriche

Le metriche CloudWatch vengono raccolte automaticamente per ogni richiesta. Puoi aggiungere metriche personalizzate:

def lambda_handler(event: EventBridgeModel, context: LambdaContext):
    metrics.add_metric(name="NewMetric", unit=MetricUnit.Count, value=1)
    return ...

Le metriche predefinite includono:

• Conteggi delle invocazioni
• Metriche di successo/fallimento
• Metriche sui cold start

Type Safety

Se hai selezionato un eventSource durante la generazione della funzione, questa viene strumentata con @event_parser di AWS Lambda Powertools. Esempio:

@event_parser(model=EventBridgeModel)
def lambda_handler(event: EventBridgeModel, context: LambdaContext):
    event.detail_type # <- type-safe con autocompletamento IDE

Questo permette di definire modelli dati usando Pydantic, in modo simile al funzionamento con Fast API.

Consiglio

Se hai dati personalizzati annidati in un evento, ad esempio in uno stream DynamoDB o un evento EventBridge, puoi beneficiare degli Envelopes per garantire il type-safety.

Se non desideri tipizzare l’evento, puoi selezionare Any come eventSource.

Deployment della funzione

Il generatore crea un costrutto CDK per il deployment nella cartella common/constructs. Puoi utilizzarlo in un’applicazione CDK:

import { MyProjectMyFunction } from ':my-scope/common-constructs';

export class ExampleStack extends Stack {
  constructor(scope: Construct, id: string) {
    // Aggiungi la funzione allo stack
    const fn = new MyProjectMyFunction(this, 'MyFunction');
  }
}

Questo configura:

1. Funzione AWS Lambda
2. Log group CloudWatch
3. Configurazione tracciamento X-Ray
4. Namespace per metriche CloudWatch

La funzione può essere utilizzata come target per qualsiasi sorgente evento lambda:

Nota

Assicurati che la sorgente dell’evento corrisponda all’opzione eventSource selezionata per garantire una corretta gestione nell’handler.

L’esempio seguente mostra il codice CDK per invocare la funzione su una schedule tramite Event Bridge:

import { EventPattern, Rule, Schedule } from 'aws-cdk-lib/aws-events';
import { LambdaFunction } from 'aws-cdk-lib/aws-events-targets';
import { MyProjectMyFunction } from ':my-scope/common-constructs';

export class ExampleStack extends Stack {
  constructor(scope: Construct, id: string) {
    // Aggiungi la funzione allo stack
    const fn = new MyProjectMyFunction(this, 'MyFunction');

    // Aggiungi la funzione a un task EventBridge
    const eventRule = new Rule(this, 'MyFunctionScheduleRule', {
      schedule: Schedule.cron({ minute: '15' }),
      targets: [new LambdaFunction(fn)],
    });
  }
}