Amazon SAM - Probar dos lambdas simultaneamente en local

Ejecución

El proceso de ejecución de una lambda tiene 2 fases.

1. El "build"

   Consiste en empaquetar toda tu app en una carpeta. Esto se hace con el comando: sam build sam build MyFunctionA --template some-path/lambda-a/template.yaml --build-dir some-path/lambda-builds/prj-python/l-a --use-container --debug En la instrucción anterior le indico que el recurso a empaquetar es MyFunctionA y está defindo en el template template.yaml
   build-dir indica donde se guardará ese compilado. En definitiva es una aplicación aislada o un microservicio.
   use-container indica que emule el empaquetado como si estuviera en un contenedor de Docker.

   Una vez ejecutado el build asi se transforma la lambda (con los requirements antes explicados): l-a │   ├── MyFunctionA │   │   ├── __init__.py │   │   ├── boto3 │   │   ├── boto3-1.17.19.dist-info │   │   ├── botocore │   │   ├── botocore-1.20.27.dist-info │   │   ├── certifi │   │   ├── certifi-2020.12.5.dist-info ... │   │   ├── index.py ... │   │   ├── requests │   │   ├── requests-2.25.1.dist-info │   │   ├── requirements.txt │   │   ├── s3transfer │   │   ├── s3transfer-0.3.4.dist-info │   │   ├── six-1.15.0.dist-info │   │   ├── six.py ... │   └── template.yaml

2. La llamada

   Como ya tenemos la función compilada podemos invocarla con sam local sam local invoke MyFunctionA --template some-path/l-a/template.yaml --event some-path/lambda-a/input.json --debug Con ese comando le decimos que ejecute el recurso: MyFunctionA que equivale a la función: function.index.fn_a pasandole como evento el json input.json

   Este es el contenido del archivo lambda-a/function/index.py donde se puede visualizar el handler

   def get_boto_client(): config_lambda = Config(retries={'total_max_attempts': 1}, read_timeout=1200) return boto3.client( 'lambda', config=config_lambda, # en mac endpoint_url='http://host.docker.internal:3050', # en windows # endpoint_url='http://localhost:3050', use_ssl=False, verify=False, ) # la función handler def fn_a(event, context): pprint("fn_a ini") now = datetime.utcnow().strftime("%Y-%m-%d-%H:%M:%S") eventjson = json.dumps(event) try: # llamda a la otra lambda Lambda B response = get_boto_client().invoke( # el alias de la otra lambda (lambda-b/template.yml) FunctionName="MyFunctionB", # que la comunicación sea por http InvocationType='RequestResponse', # no va en local. Vuelca las trazas de lambda-b en la respuesta #LogType='Tail', #datos para el parametro event de lambda-b Payload=json.dumps({"from": "This is some payload for Lambda B"}) ) except Exception as ex: ex = str(ex) return { "error": f"Error invoking Lambda B: {ex}" } if response['StatusCode'] == 200: payload = json.loads(response['Payload'].read()) pprint(payload) if "error" in payload: return { "error": f"Error response from Lambda B: {payload['error']}" } return { "event": f"input event:\n {eventjson}", "success": f"This is a response succes from Lambda A {now}", "from-lambda-b": f"{payload['success']}" } else: return { "error": f"Error in response from Lambda B status: {response['StatusCode']}" }

El punto interesante es que antes de invocar a lambda-a hay que tener en ejecución lambda-b de lo contrario nos mostraría el siguiente error: