GoogleForm,GASからAPI Gateway, Lambdaで入力情報をDynamoDBに格納する
2021/06/12
vol.26 AWS認定試験テキスト認定クラウドプラクティショナーのデモ(DynamoDB)で、DynamoDBのテーブル作成からデータの検索などのデモをしようと思うのですが、せっかくなので参加されるみなさんにデータを作ってもらおうと思いまして、GoogleFormから連携するようにしました。
データが流れる順番で解説を書きますが、実装する際は逆順になりますのでご注意ください。
目次
Google Apps Script
フォーム回答のGoogleスプレッドシートで[ツール]-[スクリプトエディタ]を選択しました。
名前をデフォルトから変更しました。
eventをそのまま、API Gatewayで作成したAPIへPOSTしました。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
function ddbdemo(event) { console.log(event); var parameters = { 'method': 'post', 'contentType': 'application/json', 'payload': JSON.stringify(event) }; var api_endpoint = 'https://xxxxxxxx.execute-api.us-east-1.amazonaws.com/v1/food'; var response = UrlFetchApp.fetch(api_endpoint, parameters); console.log(response); } |
[実行]ボタンから手動で実行して権限付与しておきました。
トリガーアイコンでトリガーメニューに遷移して、[トリガーを追加]ボタンから、スプレッドシートのフォーム送信時を選択しました。
実行数メニューで実行ログを確認できました。
Amazon API Gateway
POST, GET, GET(GSI)を用意しましたが、すべてLambdaプロキシ統合を使用しました。
AWS Lambda
POSTの例
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
import json import boto3 def lambda_handler(event, context): body = json.loads(event['body']) namedValues = body.get('namedValues') id = namedValues.get('ID')[0] date = namedValues.get('日付')[0] satisfaction = int(namedValues.get('満足度')[0]) repeat = namedValues.get('もう一度食べたい')[0] menu = namedValues.get('メニュー')[0] item = { 'id': id, 'date': date, 'satisfaction': satisfaction, 'menu': menu } if repeat == '食べたい': item['repeat'] = 'y' table = boto3.resource('dynamodb').Table('food') response = table.put_item( Item = item ) return { 'statusCode': 200, 'body': json.dumps(response) } |
namedValuesにGoogleフォームに入力された値が配列で格納されているので必要な値を取得して、DynamoDBテーブルにPutItemしています。
GETの例
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
import json import boto3 from boto3.dynamodb.conditions import Key from decimal import Decimal def decimal_default_proc(obj): if isinstance(obj, Decimal): return float(obj) raise TypeError def lambda_handler(event, context): print(event) table = boto3.resource('dynamodb').Table('food') response = table.query( KeyConditionExpression=Key('id').eq(event['queryStringParameters']['id']) ) return { 'statusCode': 200, 'body': json.dumps(response['Items'], default=decimal_default_proc) } |
URLクエリで検索するAPIですので、queryStringParametersのキーを渡しています。
decimal型が含まれているとjson.dumpsでエラーになるので、float型に変換しています。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
import json import boto3 from boto3.dynamodb.conditions import Key from decimal import Decimal def decimal_default_proc(obj): if isinstance(obj, Decimal): return float(obj) raise TypeError def lambda_handler(event, context): table = boto3.resource('dynamodb').Table('food') response = table.query( IndexName='repeat-index', KeyConditionExpression=Key('repeat').eq('y') ) return { 'statusCode': 200, 'body': json.dumps(response['Items'], default=decimal_default_proc) } |
IndexNameで’repeat-index’グローバルセカンダリインデックス(GSI)を指定しています。
Amazon DynamoDB
デモで用意したテーブルです。
テーブル名: food
パーティションキー: id(文字列)
ソートキー: date(文字列)
ローカルセカンダリインデックス(LSI):
ソートキー: satisfaction(数字)
グローバルセカンダリインデックス(GSI):
パーティションキー: repeat
デモで必要なデータを参加されたみなさんに作っていただけると、デモデータの準備に時間を割かなくていいし、ちょっとだけ参加型のデモになってよかったです。
最後までお読みいただきましてありがとうございました!
「AWS認定資格試験テキスト&問題集 AWS認定ソリューションアーキテクト - プロフェッショナル 改訂第2版」という本を書きました。

「AWS認定資格試験テキスト AWS認定クラウドプラクティショナー 改訂第3版」という本を書きました。

「ポケットスタディ AWS認定 デベロッパーアソシエイト [DVA-C02対応] 」という本を書きました。

「要点整理から攻略するAWS認定ソリューションアーキテクト-アソシエイト」という本を書きました。

「AWSではじめるLinux入門ガイド」という本を書きました。


開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。
このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。
また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。
ad
ad
関連記事
-
-
AWS WAFのマネージドルールを見てみました
Web ACLで[Add managed rule groups]を選択しました …
-
-
Amazon EC2 Auto Scalingのライフサイクルフック
EC2 Auto Scalingにライフサイクルフックという機能があります。 ス …
-
-
IAMアクセス許可の境界でIAMロールの権限を制御する
IAMユーザー自身の権限はIAMポリシーで制御できますが、IAMユーザーにIAM …
-
-
Amazon ECS Workshop for AWS Summit Online
INTRODUCTION TO AMAZON ECSに手順や必要なリンクがありま …
-
-
EC2 Auto ScalingカスタムメトリクスのモニタリングにCloudWatch検索式が便利でした
EC2 Auto Scalingで起動したインスタンスのカスタムメトリクス この …
-
-
Cloud9 Python3でpipも3にする
このブログは、2019/10/20に書いた、 Cloud9のAMIがCloud9 …
-
-
AWS DeepLens開封の儀
去年(2019年)7月にamazon.co.jpでDeepLens買えますやんっ …
-
-
Amazon Location Service入門ワークショップ-ルート計算
Amazon Location Service入門ワークショップのアプリで、ルー …
-
-
特定AWSアカウント特定リージョンのSNSトピックを削除するLambda(Python)
やりたいこと 特定アカウント内特定リージョン内のSNSトピックを全部削除したいで …
-
-
AWS CodeStarのプロジェクトテンプレートLambda+Pythonによって生成されるもの
勉強会のデモで、AWS CodeStarのプロジェクトテンプレートLambda+ …