Как вызвать функцию @ app.route, созданную в zappa извне, используя boto3? - PullRequest
Новая
       34

Как вызвать функцию @ app.route, созданную в zappa извне, используя boto3?

0 голосов
/ 19 декабря 2018

У меня есть zappa lambda, развернутая в arn: aws: lambda: us-east-1: xxxxx: function: xx-xx-prod, которая обслуживает маршрут примерно так: 

@app.route('/test', methods=['POST'])
def test():
    response = app.response_class(
      response=get_jsonstr({'test': 'OK'}),
      status=200,
      mimetype='application/json'
    )
    return response

Я хочучтобы вызвать вышеупомянутую функцию test () из другой лямбда-функции следующим образом: 

client = boto3.client('lambda', region_name='us-east-1')
r = client.invoke(
  FunctionName='arn:aws:lambda:us-east-1:xxxxx:function:xx-xx-prod',
  InvocationType='RequestResponse',
  LogType='None',
  Payload='',
)
print(r)
print(json.loads(r['Payload'].read()))

Вышеуказанный вызов выполняется следующим образом: 

{
  'ResponseMetadata': {
    'RequestId': '37ecc17b-03a9-11e9-9ea0-9dee231dfb79',
    'HTTPStatusCode': 200,
    'HTTPHeaders': {
      'date': 'Wed, 19 Dec 2018 16:14:55 GMT',
      'content-type': 'application/json',
      'content-length': '4',
      'connection': 'keep-alive',
      'x-amzn-requestid': '37ecc17b-03a9-11e9-9ea0-9dee231dfb79',
      'x-amzn-remapped-content-length': '0',
      'x-amz-executed-version': '$LATEST',
      'x-amzn-trace-id': 'root=1-5c1a6e7d-8063e5004eab150d6c967b0;sampled=0'
    },
    'RetryAttempts': 0
  },
  'StatusCode': 200,
  'ExecutedVersion': '$LATEST',
  'Payload': <botocore.response.StreamingBody object at 0x11296ce10>
}
None

Как мне сказать обработчику zappa вызватьФункция test ()?

Обновление:

Я обнаружил, что могу добавить собственный обработчик в zappa_settings.json, например так:

"lambda_handler": "lambdafilename.test"

Затем я изменил метод test () следующим образом: 

@app.route('/test', methods=['POST'])
def test(event=None, context=None):
  return json.dumps({'test': 'OK1'})

Теперь вызов возвращает ожидаемый результат:

{"test": "OK1"}

Однако с этим пользовательским обработчикомЯ теряю функциональность WSGI, которую предоставляет zappa / flask.

...