実装

• DynamoDB テーブルを作成する
  1. Amazon DynamoDB コンソールにログインします。
  2. 必ず、関数を作成しているリージョンをメモしてください。これは、ページの最上部、アカウント名の横にあります。
  3. ブルーの [テーブルの作成] ボタンをクリックします。
  4. [テーブル名] の横に、HelloWorldDatabase と入力します。
  5. [プライマリキー] フィールドに、ID と入力します。
  6. ブルーの [作成] ボタンをクリックします。
  7. 右側のパネルからテーブルの「Amazon リソースネーム (ARN) 」をコピーします (後でこのモジュールで必要になります)。
     
• IAM ポリシーを作成して Lambda 関数に追加する
  1. これでテーブルができたので、データを書き込めるように Lambda 関数を編集しましょう。新しいブラウザウィンドウで、AWS Lambda コンソールを開きます。
  2. モジュール 2 で作成した関数をクリックします (ここで紹介した例を使用している場合、「HelloWorldFunction」と呼ばれます)。
  3. DynamoDB サービスを使用できるように関数にアクセス許可を追加します。このために、AWS Identity and Access Management (IAM) を使用します。
  4. [アクセス許可] タブをクリックします。
  5. [実行ロール] ボックスで、ロールをクリックします。新しいブラウザタブが開きます。
  6. [アクセス許可ポリシー] ボックスの右側にある [インラインポリシーの追加] をクリックします。
  7. [JSON] タブをクリックします。
  8. テキスト領域に次のポリシーを貼り付けます。その際、15 行目の [リソース] フィールドのテーブルの ARN を置き換えることに注意してください。
     

  {
  "Version": "2012-10-17",
  "Statement": [
      {
          "Sid": "VisualEditor0",
          "Effect": "Allow",
          "Action": [
              "dynamodb:PutItem",
              "dynamodb:DeleteItem",
              "dynamodb:GetItem",
              "dynamodb:Scan",
              "dynamodb:Query",
              "dynamodb:UpdateItem"
          ],
          "Resource": "YOUR-TABLE-ARN"
      }
      ]
  }

  9.このポリシーにより、Lambda 関数はアイテムを読み取り、編集、または削除できますが、作成したテーブルでのみそれを実行できるように制限されます。

  10.ブルーの [ポリシーの確認] ボタンをクリックします。

  11.[名前] の横に、「HelloWorldDynamoPolicy」と入力します。

  12.ブルー の [ポリシーの作成] ボタンをクリックします。

  13.これで、このブラウザータブを閉じて、Lambda 関数のタブに戻ることができます。

  
  
• Lambda 関数を変更して DynamoDB テーブルに書き込む
  • Python
  • JavaScript
  • Java

  • Python
  • 1. [設定] タブをクリックします。
    2. 関数のコードを次のように置き換えます。
       

    # import the json utility package since we will be working with a JSON object
    import json
    # import the AWS SDK (for Python the package name is boto3)
    import boto3
    # import two packages to help us with dates and date formatting
    from time import gmtime, strftime
    
    # create a DynamoDB object using the AWS SDK
    dynamodb = boto3.resource('dynamodb')
    # use the DynamoDB object to select our table
    table = dynamodb.Table('HelloWorldDatabase')
    # store the current time in a human readable format in a variable
    now = strftime("%a, %d %b %Y %H:%M:%S +0000", gmtime())
    
    # define the handler function that the Lambda service will use as an entry point
    def lambda_handler(event, context):
    # extract values from the event object we got from the Lambda service and store in a variable
        name = event['firstName'] +' '+ event['lastName']
    # write name and time to the DynamoDB table using the object we instantiated and save response in a variable
        response = table.put_item(
            Item={
                'ID': name,
                'LatestGreetingTime':now
                })
    # return a properly formatted JSON object
        return {
            'statusCode': 200,
            'body': json.dumps('Hello from Lambda, ' + name)
        }

    3.ページの上部にあるオレンジの [保存] ボタンをクリックします。
    
  • JavaScript
  • 1. [設定] タブをクリックします。
    2. 関数のコードを次のように置き換えます。
       

    // Include the AWS SDK module
    const AWS = require('aws-sdk');
    // Instantiate a DynamoDB document client with the SDK
    let dynamodb = new AWS.DynamoDB.DocumentClient();
    // Use built-in module to get current date & time
    let date = new Date();
    // Store date and time in human-readable format in a variable
    let now = date.toISOString();
    // Define handler function, the entry point to our code for the Lambda service
    // We receive the object that triggers the function as a parameter
    exports.handler = async (event) => {
        // Extract values from event and format as strings
        let name = JSON.stringify(`Hello from Lambda, ${event.firstName} ${event.lastName}`);
        // Create JSON object with parameters for DynamoDB and store in a variable
        let params = {
            TableName:'HelloWorldDatabase',
            Item: {
                'ID': name,
                'LatestGreetingTime': now
            }
        };
        // Using await, make sure object writes to DynamoDB table before continuing execution
        await dynamodb.put(params).promise();
        // Create a JSON object with our response and store it in a constant
        const response = {
            statusCode: 200,
            body: name
        };
        // Return the response constant
        return response;
    };

    3.ページの上部にあるオレンジの [保存] ボタンをクリックします。
    
  • Java
  • 1. [設定] タブをクリックします。
    2. [関数コード] に移動し、次の JAR ファイルをアップロードします。(このチュートリアルでは、デプロイパッケージの作成はスキップします)。
    3. 「ハンドラー」を com.example.app.SavePersonHandler::handleRequest に更新します。
    4. ページの上部にあるオレンジの [保存] ボタンをクリックします。
• 変更をテストする
  1. 白の [テスト] ボタンをクリックします。
  2. グリーンの背景の「実行結果: 成功」メッセージが表示されます。
  3. 新しいブラウザタブで、DynamoDB コンソールを開きます。
  4. 左側のナビゲーションバーの [テーブル] をクリックします。
  5. このモジュールの前半で作成した HelloWorldDatabase をクリックします。
  6. 右側の [アイテム] タブをクリックします。
  7. テストイベントに一致するアイテムがここに表示されます。ここで紹介した例を使用している場合、アイテム ID は「Ada Lovelace」になります。
  8. Lambda 関数が実行されるたびに、DynamoDB テーブルが更新されます。同じ名前を使用すると、タイムスタンプのみが変更されます。