Czy funkcja Lambda AWS może wywoływać inną

Mam 2 funkcje Lambda - jedną, która tworzy wycenę, i jedną, która przekształca wycenę w zamówienie. Chciałbym, aby funkcja Order lambda wywołała funkcję Quote, aby zregenerować ofertę, a nie tylko otrzymywać ją od niezaufanego klienta.

Szukałem wszędzie, o czym myślę - ale nie widzę, jak poszedłbym do łączenia lub wywoływania funkcji ... na pewno to istnieje!

Znalazłem sposób, używając 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)
  }
});

Dokument można znaleźć tutaj: http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Lambda.html

Powinieneś połączyć swoją sieć Lambda functionsprzez SNS. Takie podejście zapewnia dobrą wydajność, opóźnienia i skalowalność przy minimalnym wysiłku.

Twoja pierwsza Lambdapublikuje wiadomości do Ciebie, SNS Topica druga Lambdasubskrybuje ten temat. Gdy tylko wiadomości dotrą do tematu, sekunda Lambdazostanie wykonana z komunikatem jako parametrem wejściowym.

Zobacz Wywoływanie funkcji Lambda za pomocą powiadomień Amazon SNS .

Możesz także użyć tego podejścia do wywoływania funkcji Lambda dla wielu kont za pośrednictwem SNS .

Oto przykładowy kod dla Pythona,

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)

Przy okazji, musisz również dodać taką politykę do swojej roli lambda

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

Od czasu zadania tego pytania firma Amazon wydała funkcje krokowe ( https://aws.amazon.com/step-functions/ ).

Jedną z podstawowych zasad AWS Lambda jest to, że można skupić się bardziej na logice biznesowej, a mniej na logice aplikacji, która łączy to wszystko razem. Funkcje krokowe pozwalają koordynować złożone interakcje między funkcjami bez konieczności pisania kodu w tym celu.

To rozwiązanie zostało wykonane przy użyciu boto3 i 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

Patrzyłem na wyłączenie SNS, dopóki nie zobaczyłem tego w dokumentacji klienta Lambda (wersja Java) :

Klient uzyskujący dostęp do AWS Lambda. Wszystkie zgłoszenia serwisowe wykonane przy użyciu tego klienta są blokowane i nie będą zwracane, dopóki zgłoszenie serwisowe się nie zakończy.

Tak więc SNS ma oczywistą zaletę: jest asynchroniczny. Twoja lambda nie będzie czekać na zakończenie kolejnej lambda.

Amazon wprowadził funkcje kroków w AWS lambda w 2016 roku. Myślę, że teraz wygodniej jest korzystać z funkcji kroków, ponieważ jest bardzo łatwa w użyciu. Możesz zbudować maszynę stanową z dwiema funkcjami lambda jako:

• do wyceny
• zamienia wycenę w zamówienie

Możesz to łatwo zrobić, jak poniżej:

Tutaj możesz ustawić pierwszy stan na wycenę, a drugi na kolejność

{
  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
    }
  }
}

Funkcje Steps naprawdę ułatwiają pisanie wielu funkcji lambda i uruchamianie ich w sekwencji lub równolegle. Możesz uzyskać więcej informacji o funkcjach kroków lambda tutaj: Funkcje kroków

Pracowałem z odpowiedzią dostarczoną przez blueskin, ale nie mogłem odczytać odpowiedzi ładunku, ponieważ InvocationType = 'Event' jest asynchroniczne , więc zmieniłem się na InvocationType = 'RequestResponse' i teraz wszystko działa dobrze.

W java możemy wykonać następujące czynności:

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

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

InvokeResult invokeResult = awsLambdaAsync.invoke(invokeRequest); 

Tutaj ładunek jest twoim strunowym obiektem java, który musi zostać przekazany jako obiekt Json do innej lambda na wypadek, gdybyś musiał przekazać pewne informacje z wywołania lambda do wywoływanej lambda.

Być może będziesz mógł skorzystać z funkcji Wodospad Async.js - zobacz przykład w dolnej części dużego fragmentu kodu w kroku 3 tego dokumentu:

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

Można wywołać funkcję lambda bezpośrednio (przynajmniej za pośrednictwem Java) stosując AWSLambdaClientsposób opisany w blogu AWS” postu .

Mam ten sam problem, ale funkcja Lambda, którą implementuję, wstawi wpis w DynamoDB, więc moje rozwiązanie używa wyzwalaczy DynamoDB.

Sprawiam, że DB wywołuje funkcję Lambda dla każdej wstawki / aktualizacji w tabeli, więc oddziela to implementację dwóch funkcji Lambda.

Dokumentacja jest dostępna tutaj: http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

Oto przewodnik: https://aws.amazon.com/blogs/aws/dynamodb-update-triggers-streams-lambda-cross-region-replication-app/

Coś w rodzaju ronda, ale po prostu nazywam punkt końcowy API dla moich funkcji lambda, kiedy muszę je połączyć . Pozwala to zdecydować podczas kodowania, czy mają być asynchroniczne, czy nie.

W przypadku, gdy nie chcesz konfigurować żądania POST, możesz po prostu ustawić proste żądanie GET z kilkoma parametrami zapytania lub wcale, aby ułatwić przekazywanie zdarzeń.

-- Edytować --

Zobacz: https://docs.aws.amazon.com/apigateway/api-reference/making-http-requests/

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

Inni wskazali na użycie SQS i funkcji krokowych. Ale oba te rozwiązania powodują dodatkowe koszty. Przejścia stanu funkcji kroku są podobno bardzo drogie.

AWS lambda oferuje pewną logikę ponownych prób. Gdzie próbuje coś 3 razy. Nie jestem pewien, czy to nadal jest ważne po uruchomieniu go użyj interfejsu API.

Oto przykład pythonowy wywołania innej funkcji lambda i otrzymuje odpowiedź. Istnieją dwa typy wywołań „RequestResponse” i „Event” . Użyj „RequestResponse”, jeśli chcesz uzyskać odpowiedź funkcji lambda, i „Event”, aby wywołać funkcję lambda asynchronicznie. Dostępne są więc oba sposoby asynchroniczny i synchroniczny.

    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)

Możesz ustawić środowisko 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();