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
デモで必要なデータを参加されたみなさんに作っていただけると、デモデータの準備に時間を割かなくていいし、ちょっとだけ参加型のデモになってよかったです。
最後までお読みいただきましてありがとうございました!
【PR】 「AWS認定試験対策 AWS クラウドプラクティショナー」という本を書きました。
【PR】 「AWSではじめるLinux入門ガイド」という本を書きました。
【PR】 「ポケットスタディ AWS認定 デベロッパーアソシエイト」という本を書きました。
【PR】 「AWS認定資格試験テキスト&問題集 AWS認定ソリューションアーキテクト - プロフェッショナル」という本を書きました。

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。
このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。
また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。
ad
ad
関連記事
-
-
Amazon Location Service入門ワークショップ-ジオフェンス
関連記事 Amazon Location Service入門ワークショップの前提 …
-
-
AWS ControlTowerで既存アカウントをまとめて追加
AWS Organizationsに新たに招待したアカウントをAWS Contr …
-
-
AWS CodeCommit 認証情報ヘルパーをmacOSに設定しました
AWS CLI 認証情報ヘルパーを使用して Linux, macOS, or U …
-
-
AWS Transfer Family EFS向けのSFTP対応サーバー
EFSファイルシステムは作成済です。 AWS Transfer Family S …
-
-
東京リージョンでAWS Control Towerランディングゾーンをセットアップする
AWS Control Towerの最初の画面で[ランディングゾーンの設定]を押 …
-
-
執筆環境(PyCharm, CodeCommit, CodePipeline, S3, Lambda, 署名付きURL)
2018年から、年に1回ぐらい商業本の執筆をさせていただいております。 2020 …
-
-
AWS CloudHSMを起動してみました
なかなか触る機会のないサービス、CloudHSM。 起動してみました。 手順はユ …
-
-
Backlogの実績工数をAmazon QuickSightで可視化してわかったこと
今年に入ってから、Backlogで個人タスクを登録しだして、予定工数、実績工数を …
-
-
VPC内のLambdaからVPCエンドポイント経由でSecrets Managerを使う
InternetGatewayのないVPCでMySQLに対して一日数回のレポーテ …
-
-
Route 53 の加重ラウンドロビンルーティングでロードバランサー
Route 53の加重ラウンドロビンで両方1に設定してみました。 上図はイメージ …