AWS - лямбда не может вызвать другую лямбду через Python SDK - PullRequest
Новая
       44

AWS - лямбда не может вызвать другую лямбду через Python SDK

1 голос
/ 09 октября 2019

Я пытаюсь вызвать лямбда-функцию из другой лямбды, используя python SDK. Обе лямбда-функции принадлежат одному и тому же VPC. Лямбда триггера содержит только скрипт Python, который вызывает вторую лямбду (loader_development). APIGateway для loader_development lambda является частным, и для него настроена политика ресурсов, которая запрещает доступ ко всем IP-адресам, которые не принадлежат этому конкретному VPC.

Мой скрипт Python в лямбда-триггере: 

from __future__ import print_function

import json
import logging
import os
from urllib2 import urlopen,Request,HTTPError
import boto3

logger = logging.getLogger()
logger.setLevel(logging.INFO)
region = os.environ['AWS_REGION']

def lambda_handler(event, context):
    invokeLambda = boto3.client('lambda', region_name = 'us-east-1')  
    request = {'resource':'/bucketstatus/latest','path':'/bucketstatus/latest','httpMethod':'GET'}
    invoke_response = invokeLambda.invoke(FunctionName='loader_development',
                                           InvocationType='RequestResponse',
                                           Payload=json.dumps(request))
    print(invoke_response['Payload'].read())

logger.info('Process Complete')

Итак, /bucketstatus/latest - это запрос GET, и эта конечная точка находится на APIGateway lambda loader_development (который является приватным). Лямбда loader_development - это приложение с загрузочной пружиной, тогда как лямбда триггера - это отдельная лямбда, в которой есть только скрипт python для вызова конечной точки лямбды loader_development для получения ответа.

Во время тестирования этого скрипта он дает статус500 и внутренняя ошибка сервера. Ошибка: 

2019-10-09 10:09:09.279 ERROR 1 --- [ main] c.a.s.proxy.AwsProxyExceptionHandler : Called exception handler for:
com.amazonaws.serverless.exceptions.InvalidRequestEventException: The incoming event is not a valid request from Amazon API Gateway or an Application Load Balancer
10:09:09 at com.amazonaws.serverless.proxy.internal.servlet.AwsProxyHttpServletRequestReader.readRequest(AwsProxyHttpServletRequestReader.java:41)
10:09:09 at com.amazonaws.serverless.proxy.internal.servlet.AwsProxyHttpServletRequestReader.readRequest(AwsProxyHttpServletRequestReader.java:28)
10:09:09 at com.amazonaws.serverless.proxy.internal.LambdaContainerHandler.proxy(LambdaContainerHandler.java:174)
10:09:09 at com.amazonaws.serverless.proxy.internal.LambdaContainerHandler.proxyStream(LambdaContainerHandler.java:209)
10:09:09 at com.trimble.roadrunner.StreamLambdaHandler.handleRequest(StreamLambdaHandler.java:49)
10:09:09 at lambdainternal.EventHandlerLoader$2.call(EventHandlerLoader.java:888)
10:09:09 at lambdainternal.AWSLambda.startRuntime(AWSLambda.java:293)
10:09:09 at lambdainternal.AWSLambda.<clinit>(AWSLambda.java:64)
10:09:09 at java.lang.Class.forName0(Native Method)
10:09:09 at java.lang.Class.forName(Class.java:348)
10:09:09 at lambdainternal.LambdaRTEntry.main(LambdaRTEntry.java:114)

Странная часть в том, что когда я пытаюсь вызвать какую-то другую лямбду (микросервис), запрос обрабатывается, и я получаю статус 200. Пример лямбда также находится внутри VPC иесть личный APIGateway.

Я действительно не уверен, что мне не хватает. Любая помощь будет принята с благодарностью!

1 Ответ

1 голос
/ 09 октября 2019

Решение WRT GitHub, я получаю это исключение, так как не включил свойство requestContext в объект запроса. Поэтому я изменил свой объект запроса так: 

request = {'resource': '/bucketstatus/latest', 'path': '/bucketstatus/latest', 'httpMethod': 'GET',
               'requestContext':{'accountId':'821665253511',
                                 'resourceId': '',
                                  'stage': 'development',
                                  'requestId': context.aws_request_id,
                                  'identity': {
                                     'cognitoIdentityPoolId': None,
                                     'accountId': None,
                                     'cognitoIdentityId': None,
                                     'caller': None,
                                     'apiKey': None,
                                     'sourceIp': '',
                                     'cognitoAuthenticationType': None,
                                     'cognitoAuthenticationProvider': None,
                                     "userArn":context.invoked_function_arn
                                  }
                                },
                "apiId": "No need"
               }

После этого изменения я смог получить правильный ответ с кодом состояния 200.

...