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版」という本を書きました。
![](https://www.sbcr.jp/wp-content/uploads/2023/01/9784815617929-1-407x596.jpg)
「AWS認定資格試験テキスト AWS認定クラウドプラクティショナー 改訂第3版」という本を書きました。
![](https://www.sbcr.jp/wp-content/uploads/2024/01/9784815625382-3-420x596.jpg)
「ポケットスタディ AWS認定 デベロッパーアソシエイト [DVA-C02対応] 」という本を書きました。
![](https://www.shuwasystem.co.jp//images/book/637791.jpg)
「要点整理から攻略するAWS認定ソリューションアーキテクト-アソシエイト」という本を書きました。
![](https://book.mynavi.jp/files/topics/135344_ext_06_0.jpg?v=1673514682)
「AWSではじめるLinux入門ガイド」という本を書きました。
![](https://www.yamamanx.com/wp-content/uploads/2023/12/81Rp5O9We6L._SY522_.jpg)
![@yamamanx](https://www.yamamanx.com/wp-content/plugins/lazy-load/images/1x1.trans.gif)
開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。
このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。
また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。
ad
ad
関連記事
-
-
Lambdaバージョンとエイリアスとトリガー
Lambdaのバージョン、エイリアスにはそれぞれ別のトリガーが設定できます。 上 …
-
-
API GatewayのアクセスログをCloudWatchに記録する
Amazon API GatewayのアクセスログをCloudWatchに記録で …
-
-
AWS CDKでリージョンをまたいだクロススタックリファレンスはできなかった
例えばこんなコードが実行できるかというと、 [crayon-66a479c047 …
-
-
AWS LambdaをVPC設定したときに「The provided execution role does not have permissions to call CreateNetworkInterface on EC2」
The provided execution role does not hav …
-
-
AWS Systems Manager AutomationでEC2の自動停止
Systems Manager Automationがない時代に、Lambdaを …
-
-
AWS DeepLensセットアップの儀
AWS DeepLensのセットアップを開始します。 AWS DeepLensを …
-
-
特定AWSアカウント特定リージョンのCloud9環境を削除するLambda(Python)
やりたいこと 特定アカウント内特定リージョン内のCloud9環境を全部削除したい …
-
-
AWS Cloud9でJavaサンプルを実行する
リモートで共有開発ができるCloud9便利ですね。 Cloud9でJavaのサン …
-
-
IAMアクセス許可の境界でIAMロールの権限を制御する
IAMユーザー自身の権限はIAMポリシーで制御できますが、IAMユーザーにIAM …
-
-
AWS Database Migration Service(DMS)チュートリアル
公式ユーザーガイドのAWS Database Migration Service …