Может ли лямбда-функция AWS вызвать другую

У меня есть 2 лямбда-функции - одна, которая производит кавычку, и одна, которая превращает кавычку в заказ. Я бы хотел, чтобы лямбда-функция Order вызывала функцию Quote для генерации цитаты, а не просто получала ее от ненадежного клиента.

Я искал повсюду, что только мог придумать, но не понимаю, как бы я поработал с цепочкой или вызовом функций ... конечно, это существует!

Я нашел способ, используя aws-sdk.

var aws = require('aws-sdk');
var lambda = new aws.Lambda({
  region: 'us-west-2' //change to your region
});

lambda.invoke({
  FunctionName: 'name_of_your_lambda_function',
  Payload: JSON.stringify(event, null, 2) // pass params
}, function(error, data) {
  if (error) {
    context.done('error', error);
  }
  if(data.Payload){
   context.succeed(data.Payload)
  }
});

Вы можете найти документ здесь: http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Lambda.html

Вы должны связать свой Lambda functionsпуть через SNS. Такой подход обеспечивает хорошую производительность, задержку и масштабируемость при минимальных усилиях.

Ваш первый Lambdaпубликует ваши сообщения, SNS Topicа второй Lambdaподписывается на эту тему. Как только сообщения поступают в тему, Lambdaвыполняется секунда с сообщением в качестве входного параметра.

См. Вызов лямбда-функций с помощью уведомлений Amazon SNS .

Вы также можете использовать этот подход для вызова лямбда-функций кросс-счета через SNS .

вот пример кода для Python,

from boto3 import client as boto3_client
from datetime import datetime
import json

lambda_client = boto3_client('lambda')

def lambda_handler(event, context):
    msg = {"key":"new_invocation", "at": datetime.now()}
    invoke_response = lambda_client.invoke(FunctionName="another_lambda_",
                                           InvocationType='Event',
                                           Payload=json.dumps(msg))
    print(invoke_response)

Кстати, вам нужно будет добавить такую ​​политику в вашу лямбда-роль

   {
        "Sid": "Stmt1234567890",
        "Effect": "Allow",
        "Action": [
            "lambda:InvokeFunction"
        ],
        "Resource": "*"
    }

Поскольку этот вопрос был задан, Amazon выпустила пошаговые функции ( https://aws.amazon.com/step-functions/ ).

Одним из основных принципов AWS Lambda является то, что вы можете больше сосредоточиться на бизнес-логике и меньше на логике приложения, которая связывает все это вместе. Шаговые функции позволяют организовать сложные взаимодействия между функциями без необходимости написания кода для этого.

Это решение сделано с использованием boto3 и Python:

import boto3
import json

invokeLambda = boto3.client('lambda', region_name='eu-west-1')

def lambda_handler(event, context):
    invokeLambda.invoke(FunctionName = 'function_name', InvocationType = 'RequestResponse', Payload = json.dumps(event))

    return True

Я смотрел на вырезание SNS, пока не увидел это в документации клиента Lambda (версия Java) :

Клиент для доступа к AWS Lambda. Все сервисные вызовы, сделанные с помощью этого клиента, блокируются и не возвращаются, пока сервисный вызов не завершится.

Так что у SNS есть очевидное преимущество: он асинхронный. Ваша лямбда не будет ждать окончания следующей лямбды.

В 2016 году Amazon представила функции шага в AWS lambda. Думаю, теперь удобнее использовать функцию шага, поскольку их действительно легко использовать. Вы можете создать конечный автомат с двумя лямбда-функциями:

• производить цитату
• превращает цитату в заказ

Вы можете легко сделать это, как показано ниже:

Здесь вы можете иметь первое состояние для создания цитаты, а другое для превращения в порядок

{
  Comment: "Produce a quote and turns into an order",
  StartAt: "ProduceQuote",
  States: {
    ProduceQuote: {
      "Type": Task,
      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
      "next": TurnsToOrder
    }
    TurnsToOrder: {
      Type: Task,
      Resource: "arn:aws:lambda:us-east-1:123456789012:function:ProduceQuote",
      end: true
    }
  }
}

Функция Steps позволяет действительно легко написать несколько лямбда-функций и выполнять их последовательно или параллельно. Вы можете получить больше информации о функциях лямбда-шагов здесь: Функции шагов

Я работал с ответом, предоставленным blueskin, но не смог прочитать ответ Payload, потому что InvocationType = 'Event' является асинхронным , поэтому я изменил на InvocationType = 'RequestResponse', и теперь все работает хорошо.

В Java мы можем сделать следующее:

AWSLambdaAsync awsLambdaAsync = AWSLambdaAsyncClientBuilder.standard().withRegion("us-east-1").build();

InvokeRequest invokeRequest = new InvokeRequest();
invokeRequest.withFunctionName("youLambdaFunctionNameToCall").withPayload(payload);

InvokeResult invokeResult = awsLambdaAsync.invoke(invokeRequest); 

Здесь полезная нагрузка - это ваш строковый java-объект, который нужно передать как Json-объект другой лямбде, если вам нужно передать некоторую информацию от вызова лямбды к вызываемой лямбде.

Возможно, вы сможете использовать функцию водопада Async.js - см. Нижнюю часть большого фрагмента кода в шаге 3 этого документа, например:

https://aws.amazon.com/blogs/compute/better-together-amazon-ecs-and-aws-lambda/

Вы можете вызвать функцию лямбда непосредственно (по крайней мере , с помощью Java), используя , AWSLambdaClientкак описано в блоге АМС» пост .

У меня та же проблема, но реализованная мной функция Lambda вставит запись в DynamoDB, поэтому мое решение использует триггеры DynamoDB.

Я заставляю БД вызывать функцию Lambda для каждой вставки / обновления в таблице, так что это разделяет реализацию двух функций Lambda.

Документация находится здесь: http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

Вот пошаговое руководство: https://aws.amazon.com/blogs/aws/dynamodb-update-triggers-streams-lambda-cross-region-replication-app/

Что-то вроде обходного решения, но я просто вызываю конечную точку API для своих лямбда-функций, когда мне нужно их связать. Это позволяет вам при кодировании решить, хотите ли вы, чтобы они были асинхронными или нет.

Если вы не хотите устанавливать запрос POST, вы можете просто настроить простой запрос GET с парой или без параметров строки запроса для простой передачи события.

-- Редактировать --

Смотрите: https://docs.aws.amazon.com/apigateway/api-reference/making-http-requests/

и: http://docs.aws.amazon.com/lambda/latest/dg/with-on-demand-https-example.html

Другие указали на использование SQS и пошаговых функций. Но оба эти решения добавляют дополнительную стоимость. Переходы состояний ступенчатой ​​функции предположительно очень дороги.

AWS лямбда предлагает некоторую логику повторов. Где то пробует 3 раза. Я не уверен, что это все еще действует, когда вы запускаете его с помощью API.

Вот пример на Python вызова другой лямбда-функции и получения ее ответа. Существует два типа вызовов: «RequestResponse» и «Event» . Используйте «RequestResponse», если вы хотите получить ответ лямбда-функции, и используйте «Событие», чтобы вызвать лямбда-функцию асинхронно. Таким образом, доступны оба способа: асинхронный и синхронный.

    lambda_response = lambda_client.invoke(
                FunctionName = lambda_name,
                InvocationType = 'RequestResponse',
                Payload = json.dumps(input)
                )
    resp_str = lambda_response['Payload'].read()
    response = json.loads(resp_str)

Вы можете установить среду AWS_REGION.

assert(process.env.AWS_REGION, 'Missing AWS_REGION env (eg. ap-northeast-1)');
const aws = require('aws-sdk');
const lambda = new aws.Lambda();