Dapatkah fungsi AWS Lambda memanggil yang lain

Saya memiliki 2 fungsi Lambda - yang menghasilkan penawaran dan yang mengubah penawaran menjadi pesanan. Saya ingin fungsi Order lambda untuk memanggil fungsi Penawaran untuk membuat ulang penawaran, daripada hanya menerimanya dari klien yang tidak terpercaya.

Saya telah mencari di mana-mana yang dapat saya pikirkan - tetapi tidak dapat melihat bagaimana saya akan melakukan chaining atau memanggil fungsi ... pasti ini ada!

Saya menemukan cara menggunakan 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)
  }
});

Anda dapat menemukan dokumen di sini: http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Lambda.html

Anda harus rantai Lambda functionsvia AndaSNS . Pendekatan ini memberikan kinerja yang baik, latensi, dan skalabilitas untuk upaya minimal.

Pertama Anda Lambdamempublikasikan pesan ke Anda SNS Topicdan yang kedua Lambdaberlangganan topik ini. Begitu pesan tiba di topik, keduaLambda dieksekusi dengan pesan sebagai parameter inputnya.

Lihat Meminta fungsi Lambda menggunakan notifikasi Amazon SNS .

Anda juga dapat menggunakan pendekatan ini untuk Menjalankan fungsi Lambda lintas-akun melalui SNS .

inilah kode contoh untuk 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)

Btw, Anda perlu menambahkan kebijakan seperti ini ke peran lambda Anda juga

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

Sejak pertanyaan ini diajukan, Amazon telah merilis Fungsi Langkah ( https://aws.amazon.com/step-functions/ ).

Salah satu prinsip inti di balik AWS Lambda adalah bahwa Anda dapat lebih fokus pada logika bisnis dan lebih sedikit pada logika aplikasi yang mengikat semuanya. Fungsi langkah memungkinkan Anda mengatur interaksi kompleks antar fungsi tanpa harus menulis kode untuk melakukannya.

Solusi ini dilakukan dengan menggunakan boto3 dan 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

Saya sedang melihat memotong SNS sampai saya melihat ini di dokumen klien Lambda (versi Java) :

Klien untuk mengakses AWS Lambda. Semua panggilan layanan yang dibuat menggunakan klien ini diblokir, dan tidak akan kembali sampai panggilan layanan selesai.

Jadi SNS memiliki keuntungan yang jelas: tidak sinkron. Lambda Anda tidak akan menunggu untuk lambda berikutnya selesai.

Amazon telah memperkenalkan fungsi langkah di AWS lambda pada 2016. Saya pikir, sekarang lebih nyaman menggunakan fungsi langkah karena sangat mudah untuk menggunakannya. Anda dapat membangun mesin negara dengan dua fungsi lambda sebagai:

• untuk menghasilkan penawaran
• mengubah kutipan menjadi pesanan

Anda dapat dengan mudah melakukannya seperti di bawah ini:

Di sini Anda dapat memiliki status pertama untuk menghasilkan kutipan dan yang lainnya berubah menjadi urutan

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

Fungsi langkah membuatnya sangat mudah untuk menulis beberapa fungsi lambda dan dijalankan secara berurutan atau paralel. Anda dapat memperoleh informasi lebih lanjut tentang fungsi langkah lambda di sini: Fungsi Langkah

Saya bekerja dengan jawaban yang diberikan oleh blueskin tetapi saya tidak dapat membaca respons Payload karena InvocationType = 'Event' adalah async , jadi saya berubah sebagai InvocationType = 'RequestResponse' dan sekarang semua berfungsi dengan baik.

Di java, kita bisa melakukan hal berikut:

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

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

InvokeResult invokeResult = awsLambdaAsync.invoke(invokeRequest); 

Di sini, payload adalah objek java Anda yang di- string yang harus dilewatkan sebagai objek Json ke lambda lain jika Anda perlu meneruskan beberapa informasi dari memanggil lambda ke yang disebut lambda.

Anda mungkin dapat memanfaatkan fitur Air Terjun Async.js - lihat bagian bawah potongan kode besar pada Langkah 3 dari dokumen ini sebagai contoh:

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

Anda dapat menjalankan fungsi lambda secara langsung (setidaknya melalui Java) dengan menggunakan AWSLambdaClientseperti yang dijelaskan dalam posting blog AWS .

Saya mengalami masalah yang sama tetapi fungsi Lambda yang saya implementasikan akan memasukkan entri dalam DynamoDB, jadi solusi saya menggunakan DynamoDB Triggers.

Saya membuat DB memanggil fungsi Lambda untuk setiap sisipan / pembaruan dalam tabel, jadi ini memisahkan implementasi dua fungsi Lambda.

Dokumentasi ada di sini: http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

Berikut adalah panduan penelusuran: https://aws.amazon.com/blogs/aws/dynamodb-update-triggers-streams-lambda-cross-region-replication-app/

Semacam solusi bundaran tetapi saya hanya memanggil titik akhir API untuk fungsi lambda saya ketika saya perlu rantai mereka. Ini memungkinkan Anda untuk memutuskan sambil mengkodekan apakah Anda ingin mereka tidak sinkron atau tidak.

Jika Anda tidak ingin mengatur permintaan POST, Anda hanya bisa mengatur permintaan GET sederhana dengan pasangan, atau tidak sama sekali, parameter string kueri untuk melewati peristiwa mudah.

- Edit -

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

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

Lainnya menunjukkan untuk menggunakan SQS dan Step Functions. Namun kedua solusi ini menambah biaya tambahan. Langkah Fungsi transisi keadaan konon sangat mahal.

AWS lambda menawarkan beberapa logika coba lagi. Di mana ia mencoba sesuatu selama 3 kali. Saya tidak yakin apakah itu masih berlaku ketika Anda memicu menggunakan API.

Ini adalah contoh python untuk memanggil fungsi lambda lain dan mendapatkan responsnya. Ada dua jenis doa 'RequestResponse' dan 'Event' . Gunakan 'RequestResponse' jika Anda ingin mendapatkan respons fungsi lambda dan gunakan 'Event' untuk memanggil fungsi lambda secara tidak sinkron. Jadi kedua cara asinkron dan sinkron tersedia.

    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)

Anda dapat mengatur lingkungan 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();