Lambda関数の実行と呼び出し
この章では、Lambda関数の実行と呼び出しのプロセスとそれに関連する手順について詳しく説明します。
AWS Lambda実行モデル
AWSの実行は、AWS Lambda Functionに追加された設定の詳細に依存します。 関数が作成されると、AWS Lambda関数の実行に使用される memory と* timeが割り当てられます*があります。
設定の詳細を利用して、AWS Lambdaは実行コンテキストを作成します。 実行コンテキストは一時的なランタイム環境であり、データベース接続、httpエンドポイント、サードパーティライブラリなどの外部依存関係があれば準備が完了しています。
AWS Lambda関数が初めて呼び出されたとき、またはラムダ関数が更新された場合、実行コンテキストのセットアップのために遅延がほとんど追加されません。 ただし、後続の呼び出しは最初の呼び出しに比べて高速です。 AWS Lambdaは、Lambda関数の呼び出し時間が短くなると、実行コンテキストの再利用を再試行します。
実行コンテキストの再利用には、次の意味があります-
- Lambdaの実行のために行われたデータベース接続がある場合、その接続は再利用のために維持されます。 そのため、Lambdaコードは、接続が最初にチェックされ、存在し、再利用されるようにする必要があります。それ以外の場合は、新しい接続を新しく作成する必要があります。
- 実行コンテキストは、 /tmp ディレクトリに500MBのディスク容量を維持します。 必要なデータはこのディレクトリにキャッシュされます。 コードに追加のチェックを行って、データが存在するかどうかを確認できます。
- Lambda関数が呼び出されたときにコールバックまたはバックグラウンドプロセスが完了していない場合、ラムダ関数が再度呼び出されたときに実行が開始されます。 そのようなことを行う必要がない場合は、関数の実行が完了したときにプロセスがすべて正しく終了することを確認してください。
実行コンテキストと、tmpディレクトリに保存されているデータを使用する必要があります。 新しいデータを作成する前に、コードに必要なチェックを追加して、必要なデータが存在するかどうかを確認する必要があります。 これにより、実行中の時間が節約され、より高速になります。
AWS Lambda関数を呼び出す
AWS CLIを使用してAWS Lambda関数を作成する
コマンド
値を指定したコマンド
出力は次のようになります-
値を持つコマンド
AWSコンソールで作成された関数は以下のとおりです-
作成された関数
コードエントリタイプ 既存のロール
これで、次のコマンドを使用して関数を呼び出すことができます： invoke
オプション
- -function-name-*呼び出す関数の名前を指定します。
-invocation-type（string）-*デフォルトでは、invokation-typeは *requestresponse です。 invokation-typeで使用できる値は、 RequestResponse、Event 、および DryRun です。
- イベント呼び出しタイプは、非同期応答に使用されます。
- DryRunは、Lambda関数を実行せずに検証する場合に使用します。
-log-type-*呼び出しタイプがRequestResponseの場合、 *Tail になります。 最後の4KBのbase64でエンコードされたログデータを提供します。 可能な値は Tail および None です。
- -client-context-*クライアント固有の詳細をLambda関数に渡すことができます。 clientcontextは、json形式でbase64エンコードされている必要があります。 最大ファイルサイズは3583バイトです。
- -payload-*ラムダ関数へのjson形式の入力。
-qualifier- Lambda関数のバージョンまたはエイリアス名を指定できます。 関数バージョンを渡すと、apiは修飾された関数arnを使用してLambda関数を呼び出します。 エイリアス名を指定すると、APIはエイリアスARNを使用してLambda関数を呼び出します。
- outfile-*これは、コンテンツが保存されるファイル名です。
値を指定したコマンド
コマンド値
ペイロードオプションを使用して、以下に示すように、json形式でダミーイベントをラムダ関数に送信できます。
関連するAWS Lambdaコードは次のとおりです-
コードにコンソール event.name と event.addr があることに注意してください。 さて、次のように名前とアドレスでイベントを送信するためにaws cliでペイロードオプションを使用してみましょう-
その後、payloadは、示されているようにjson入力を持つファイルパスとして入力を取ります-
対応する出力は以下のとおりです-
対応する出力
出力は次のようにファイル C：\ clioutput \ outputfile.txt に保存されます-
サンプルイベント
サンプルイベントを渡すことで、AWS Lambda関数をテストできます。 このセクションでは、AWSサービスのサンプルイベントをいくつか示します。 invoke コマンドを使用して、いずれかのサービスでトリガーされたときに出力をテストできます。 以下の対応するサンプルイベントに指定されたコードを観察します-
Amazon S3 Putサンプルイベント
s3プットイベントからファイルの*詳細を取得するには、次のコマンドを使用できます-
バケット名を取得するには、次のコマンドを使用できます-
Amazon S3サンプルイベントの削除
Amazon DynamoDB
Amazon DynamoDBは、DynamoDBテーブルに変更が加えられた場合、AWS Lambdaのイベントになります。 DynamodDBテーブルのエントリの追加、レコードの更新、削除などの操作を実行できます。
DynamoDBの追加、挿入、削除イベントのサンプルイベントを次に示します-
Amazon簡易通知サービス
AWS Lambdaは、* Simple Notification Service（SNS）*で作成された通知の処理に役立ちます。 SNSにメッセージが公開されるたびに、メッセージの詳細を含むSNSイベントでLambda関数をトリガーできます。 このメッセージはLambda関数内で処理でき、要件に従って他のサービスにさらに送信できます。
メッセージが入力されると、SNSはLambda関数をトリガーします。 エラーがLambda関数を呼び出そうとすると、SNSは最大3回までラムダ関数の呼び出しを再試行します。
Amazon SNSサンプルイベント
AWS Lambda関数で利用可能なすべての詳細を備えたサンプルイベントは、さらにプロセスを実行するために以下に示されています-
Amazon Simple Mail Service
Amazon Simple Mail Serviceは、メッセージの送信とメッセージの受信に使用できます。 AWS Lambda関数は、メッセージの受信時にSimple Mail Serviceで呼び出すことができます。
Amazon SES Eメール受信サンプルイベント
AWS Lambda内で使用される場合のSESイベントの詳細を以下に示します-
{
"Records": [{
"eventVersion": "1.0",
"ses": {
"mail": {
"commonHeaders": {
"from": [
"Jane Doe <janedoe@example.com>"
],
"to": [
"johndoe@Source.com"
],
"returnPath": "janedoe@example.com",
"messageId": "<0123456789Source.com>",
"date": "Wed, 7 Oct 2015 12:34:56 -0700",
"subject": "Test Subject"
},
"example": "janedoe@example.com",
"timestamp": "1970-01-01T00:00:00.000Z",
"destination": [
"johndoe@example.com"
],
"headers": [{
"name": "Return-Path",
"value": "<janedoe@example.com>"
},
{
"name": "Received",
"value": "from mailer.example.com (mailer.example.com [203.0.113.1]) by inbound-smtp.us-west-2.amazonaws.com with SMTP id o3vrnil0e2ic for johndoe@example.com; Wed, 07 Oct 2015 12:34:56 +0000 (UTC)"
},
{
"name": "DKIM-Signature",
"value": "v=1; a=rsa-sha256; c=relaxed/relaxed; d=example.com; s=example; h=mime-version:from:date:message-id:subject:to:content-type; bh=jX3F0bCAI7sIbkHyy3mLYO28ieDQz2R0P8HwQkklFj4=; b=sQwJ+LMe9RjkesGu+vqU56asvMhrLRRYrWCbV"
},
{
"name": "MIME-Version",
"value": "1.0"
},
{
"name": "From",
"value": "Jane Doe <janedoe@example.com>"
},
{
"name": "Date",
"value": "Wed, 7 Oct 2015 12:34:56 -0700"
},
{
"name": "Message-ID",
"value": "<0123456789example.com>"
},
{
"name": "Subject",
"value": "Test Subject"
},
{
"name": "To",
"value": "johndoe@example.com"
},
{
"name": "Content-Type",
"value": "text/plain; charset=UTF-8"
}],
"headersTruncated": false,
"messageId": "o3vrnil0e2ic28tr"
},
"receipt": {
"recipients": [
"johndoe@example.com"
],
"timestamp": "1970-01-01T00:00:00.000Z",
"spamVerdict": {
"status": "PASS"
},
"dkimVerdict": {
"status": "PASS"
},
"processingTimeMillis": 574,
"action": {
"type": "Lambda",
"invocationType": "Event",
"functionArn": "arn:aws:lambda:us-west-2:012345678912:function:example"
},
"spfVerdict": {
"status": "PASS"
},
"virusVerdict": {
"status": "PASS"
}
}
},
"eventexample": "aws:ses"
}]
}
Amazon Cloudwatchログ
AWS Lambdaは、 CloudWatch Logs Subscriptions を使用してAmazon CloudWatch Logsからトリガーできます。 CloudWatch Logsサブスクリプションには、AWS Lambda内で処理および分析できる、または他のシステムへのロードに使用できるログに関するデータのリアルタイムデータがあります。
Amazon CloudWatch Logsサンプルイベント
Amazon API Gateway
AWS Lambda関数は、 https URLで呼び出すことができます。 ITは GET、POST、PUT で実行できます。 https URLが呼び出されると、AWS Lambda関数もトリガーされ、get/postを使用してhttpsに渡されたデータをAWS Lambda内で使用可能にして、DynamoDBへの挿入やメールの送信などに使用できます。
API Gatewayプロキシリクエストイベント
{
"path": "/test/hello",
"headers": {
"Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8",
"Accept-Encoding": "gzip, deflate, lzma, sdch, br",
"Accept-Language": "en-US,en;q=0.8",
"CloudFront-Forwarded-Proto": "https",
"CloudFront-Is-Desktop-Viewer": "true",
"CloudFront-Is-Mobile-Viewer": "false",
"CloudFront-Is-SmartTV-Viewer": "false",
"CloudFront-Is-Tablet-Viewer": "false",
"CloudFront-Viewer-Country": "US",
"Host": "wt6mne2s9k.execute-api.us-west-2.amazonaws.com",
"Upgrade-Insecure-Requests": "1",
"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/52.0.2743.82 Safari/537.36 OPR/39.0.2256.48",
"Via": "1.1 fb7cca60f0ecd82ce07790c9c5eef16c.cloudfront.net (CloudFront)",
"X-Amz-Cf-Id": "nBsWBOrSHMgnaROZJK1wGCZ9PcRcSpq_oSXZNQwQ10OTZL4cimZo3g==",
"X-Forwarded-For": "192.168.100.1, 192.168.1.1",
"X-Forwarded-Port": "443",
"X-Forwarded-Proto": "https"
},
"pathParameters": {
"proxy": "hello"
},
"requestContext": {
"accountId": "123456789012",
"reexampleId": "us4z18",
"stage": "test",
"requestId": "41b45ea3-70b5-11e6-b7bd-69b5aaebc7d9",
"identity": {
"cognitoIdentityPoolId": "",
"accountId": "",
"cognitoIdentityId": "",
"caller": "",
"apiKey": "",
"exampleIp": "192.168.100.1",
"cognitoAuthenticationType": "",
"cognitoAuthenticationProvider": "",
"userArn": "",
"userAgent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/52.0.2743.82 Safari/537.36 OPR/39.0.2256.48",
"user": ""
},
"reexamplePath": "/{proxy+}",
"httpMethod": "GET",
"apiId": "wt6mne2s9k"
},
"reexample": "/{proxy+}",
"httpMethod": "GET",
"queryStringParameters": {
"name": "me"
},
"stageVariables": {
"stageVarName": "stageVarValue"
}
}
API Gatewayプロキシ応答イベント
