• 全ての記事
  • ITスキル
  • AWSトレーニングコースで使用している質問フォームのアーキテクチャ(2019年6月版)
catch-img

AWSトレーニングコースで使用している質問フォームのアーキテクチャ(2019年6月版)

山下 光洋（やました みつひろ）ITスキル

AWS山下光洋

「コース中の質問をサーバーレスなアーキテクチャで受けて共有」で掲載しました質問フォームのアーキテクチャを一部変更しましたので、今回は設計を書いておきたいと思います。

動作などは上記リンクをご参照ください。

目次[非表示]

  1. 1.Amazon Route 53
  2. 2.AWS Certificate Manager
  3. 3.Amazon CloudFront
  4. 4.Amazon S3
  5. 5.Amazon API Gateway
  6. 6.最初のAWS Lambda
  7. 7.Amazon SNS, Amazon SQS
  8. 8.Teamsに投稿するAWS Lambda
  9. 9.Backlogにチケット登録するAWS Lambda
  10. 10.DynamoDBにデータを入れるAWS Lambda


Amazon Route 53

個人で所有しているドメインでアクセスできるようにしていますので、Route 53のAレコードのエイリアスで、CloudFrontのドメインを指定しています。



AWS Certificate Manager

Certificate Managerでドメインの証明書を発行して、Route 53のCNAMEでドメイン認証をしています。



Amazon CloudFront

CloudFrontにはCertificate Managerで発行した証明書を設定しています。

オリジンにはS3バケットを指定して、OAIにてバケットへのCloudFrontを介さない直接のアクセスをできないようにしています。

Amazon S3

S3のバケットポリシー

{
    "Version": "2008-10-17",
    "Id": "PolicyForCloudFrontPrivateContent",
    "Statement": [
        {
            "Sid": "1",
            "Effect": "Allow",
            "Principal": {
                "AWS": "arn:aws:iam::cloudfront:user/CloudFront Origin Access Identity XXXXXXXXX"
            },
            "Action": "s3:GetObject",
            "Resource": "arn:aws:s3:::qa.trainocate/*"
        }
    ]
}


S3バケットにはHTML, CSS, JavaScriptを配置して入力フォームをCloudFront経由で配信しています。



Amazon API Gateway

[質問]ボタンが押されると質問内容がURLパラメータとしてAPI GatewayでデプロイしたAPIにPOSTされます。

API GatewayではURlパラメータをJSONに変換してLambdaにEventデータとして渡しています。


最初のAWS Lambda

最初のLambdaはメッセージを受け取って、SNSトピックへ発行します。

import logging
import boto3
import traceback
import json

logger = logging.getLogger()
logger.setLevel(logging.INFO)

def lambda_handler(event, context):
    logger.info(event)
    try:
        sns = boto3.client('sns')
        qa_topic = 'Qa'
        snsTopicArn = [t['TopicArn'] for t in sns.list_topics()['Topics'] if t['TopicArn'].endswith(':' + qa_topic)][0]

        sns.publish(
            TopicArn=snsTopicArn,
            Message=json.dumps(event),
            Subject='question'
        )

    except:
        logger.error(traceback.format_exc())



Amazon SNS, Amazon SQS

SNSトピックは3つのSQSキューへメッセージをファンアウトします。


Teamsに投稿するAWS Lambda

1つ目のSQSキューからメッセージを受信したLambdaはTeamsに通知します。

import logging, boto3, json, traceback, os
from teams import Teams

logger = logging.getLogger()
logger.setLevel(logging.INFO)


def lambda_handler(event, context):
    teams = Teams()
    try:
        for record in event['Records']:
            message_body = json.loads(record['body'])
            message = json.loads(message_body['Message'])
            
            project_id = message['project_id']
            description = message['contact_detail'].replace(
                'newline',
                '\n'
            )

            teams.send_message(
                '受講者からの質問',
                '{description}  {project_id}'.format(
                    description=description,
                    project_id=project_id
                )
            )
    except:
        logger.error(traceback.format_exc())
        raise Exception(traceback.format_exc())


Backlogにチケット登録するAWS Lambda

2つ目のSQSキューからメッセージを受信したLambdaはBacklog APIにPOSTしてチケット登録を行います。

import logging, boto3, json, traceback, os, requests

logger = logging.getLogger()
logger.setLevel(logging.INFO)


def lambda_handler(event, context):
    try:
        backlog_key = os.environ.get('BACKLOG_KEY', '')
        project_id = os.environ.get('PROJECT_ID', '')
        issue_type_id = os.environ.get('ISSUE_TYPE_ID', '')
        priority_id = os.environ.get('PRIORITY_ID', '')
        assignee_id = os.environ.get('ASSIGNEE_ID', '')
        backlog_url =os.environ.get('BACKLOG_URL', '')
        mile_stone_id = os.environ.get('MILE_STONE_ID', '')
        

        for record in event['Records']:
            message_body = json.loads(record['body'])
            logger.info(message_body)
            logger.info(message_body['Message'])
            message = json.loads(message_body['Message'])
            
            summary =  message['contact_detail'].replace(
                'newline',
                ''
            )[:50]
            description = message['contact_detail'].replace(
                'newline',
                '\n'
            )
            
            payload_dic = {
                'projectId': project_id,
                'issueTypeId': issue_type_id,
                'priorityId': priority_id,
                'assigneeId': assignee_id,
                'milestoneId': [mile_stone_id],
                'summary': summary,
                'description': description
            }
            
            headers = {
                'Content-Type': 'application/json'
            }

            response = requests.post(
                backlog_url + backlog_key,
                data=json.dumps(
                    payload_dic
                ),
                headers = headers
            )

            if response.text:
                logger.info(response.text)
            else:
                logger.info(response)

    except:
        logger.error(traceback.format_exc())
        raise Exception(traceback.format_exc())


DynamoDBにデータを入れるAWS Lambda

3つ目のSQSキューからメッセージを受信したLamndaはリクエスト内容と時間、送信元IPアドレスなどの情報とともにDynamoDBへ書きます。

import traceback, json, os, logging, boto3
from datetime import datetime

logger = logging.getLogger()
logger.setLevel(logging.INFO)


def lambda_handler(event, context):
    logger.info(event)
    try:
        dynamodb = boto3.resource('dynamodb')
　　    table = dynamodb.Table('qa')
        with table.batch_writer() as batch:
            for record in event['Records']:
                message_body = json.loads(record['body'])
                message = json.loads(message_body['Message'])
                message['submit_datetime'] = datetime.now().strftime('%Y%m%d%H%M%S%f')
                batch.put_item(Item=message)

    except:
        logger.error(traceback.format_exc())




山下 光洋（やました みつひろ）

山下 光洋（やました みつひろ）

トレノケート株式会社 講師。AWS Authorized Instructor Champion / AWS認定インストラクター(AAI) / AWS 認定ソリューションアーキテクト - プロフェッショナル /AWS認定DevOpsエンジニア - プロフェッショナル / AWS 認定デベロッパー - アソシエイト / AWS 認定 SysOps アドミニストレーター - アソシエイト /　AWS 認定クラウドプラクティショナー / kintone認定 カスタマイズスペシャリスト他。AWS認定インストラクターとしてAWS認定コースを実施。毎年1,500名以上に受講いただいている。AWS 認定インストラクターアワード2018, 2019を日本で唯一受賞。著書『AWSではじめるLinux入門ガイド』（マイナビ出版社）。共著書『AWS認定試験対策 AWS クラウドプラクティショナー』（SBクリエイティブ社）。前職では2016年にAWS Summitにパネラーとして参加。その前はLotus Technical Award 2009 for Best Architectとして表彰されている。また、各コミュニティの運営にも個人的に関わり、勉強会にてスピーカーや参加をしている。

前の記事

prev-article-image

AWS IAMの認証(マネジメントコンソールとCLI)の違いとIAMロール

次の記事

next-article-image

玄人お断り？ 簡単操作で注目の Cisco Meraki を使いこなすには

無料ダウンロード

オススメコンテンツ

   

オススメ記事

© Trainocate Japan, Ltd. 2008-2023

© Basic Inc. All Rights Reserved.