Lambda: funciones serverless para datos

1# handler.py — una función Lambda básica
2import json
3import boto3
4
5def handler(event, context):
6    """
7    event: lo que disparó la función (datos del trigger)
8    context: metadata de la ejecución (tiempo restante, memoria, etc.)
9    """
10    # Ejemplo: trigger de S3 — un archivo nuevo llegó al bucket
11    for record in event.get('Records', []):
12        bucket = record['s3']['bucket']['name']
13        key = record['s3']['object']['key']
14        size = record['s3']['object']['size']
15
16        print(f"Nuevo archivo: s3://{bucket}/{key} ({size} bytes)")
17
18        # Lógica: validar, mover, notificar, disparar pipeline...
19        if key.endswith('.csv') and size > 0:
20            procesar_csv(bucket, key)
21        elif size == 0:
22            notificar_error(f"Archivo vacío: {key}")
23
24    return {'statusCode': 200, 'body': json.dumps('OK')}
25
26def procesar_csv(bucket, key):
27    """Ejemplo: mover CSV a zona de procesamiento."""
28    s3 = boto3.client('s3')
29    # Copiar a processed/
30    s3.copy_object(
31        Bucket=bucket,
32        Key=f"processing/{key.split('/')[-1]}",
33        CopySource={'Bucket': bucket, 'Key': key}
34    )
35    print(f"Movido a processing/")

La función handler recibe un event (quién la disparó) y un context (metadata)

1import boto3
2import json
3import zipfile
4import io
5
6lambda_client = boto3.client('lambda', endpoint_url='http://localhost:4566',
7                             aws_access_key_id='test', aws_secret_access_key='test',
8                             region_name='eu-west-1')
9
10# Crear el ZIP con el código de la función
11code = '''
12import json
13def handler(event, context):
14    print(f"Evento recibido: {json.dumps(event)}")
15    return {"statusCode": 200, "body": "Procesado OK"}
16'''
17
18zip_buffer = io.BytesIO()
19with zipfile.ZipFile(zip_buffer, 'w') as zf:
20    zf.writestr('handler.py', code)
21zip_buffer.seek(0)
22
23# Crear la función Lambda
24lambda_client.create_function(
25    FunctionName='procesar-archivo-raw',
26    Runtime='python3.11',
27    Role='arn:aws:iam::000000000000:role/LambdaETLRole',
28    Handler='handler.handler',
29    Code={'ZipFile': zip_buffer.read()},
30    Timeout=300,        # 5 minutos máximo
31    MemorySize=256,     # 256MB RAM
32    Environment={
33        'Variables': {
34            'BUCKET_OUTPUT': 'fashionstore-datalake',
35            'PREFIX_OUTPUT': 'processing/'
36        }
37    }
38)
39print("✅ Lambda creada: procesar-archivo-raw")

Crear función Lambda programáticamente — el código va en un ZIP