webフォームからの問い合わせをRedmineに自動登録して対応状況を管理する(API Gateway + Lambda)

2018/01/05

先日、検証目的で作成したRedmineの冗長化の一機能として、webフォームから問い合わせがあった場合に、Redmineのチケットを自動登録して対応状況を管理出来るようにしてみました。

webフォームはS3で静的ホスティングを使っています。
CloudFrontでS3をオリジンにしてwebフォームを配信しています。
ACMでSSL証明書を無料で取得しています。
webフォームから送信された情報はAmazon API Gateway、AWS Lambdaを経由してDynamoDBテーブルへ格納されます。
DynamoDBテーブルに格納されたデータはDynamoDB StreamからLambdaが実行されてSQSへキューを送信します。
SQSからキューを受信したLambdaがRedmine APIをコールしてチケットを作成します。

※ DynamoDBを介しているのは、Redmineへ送る必要のないデータも含めて記録しておくためです。
※ SQSを介しているのはRedmine APIがコール出来ない場合に再処理を容易にするためと、再処理回数をSQSのデッドレターキュー機能で制限したいためです。
※ 4で6の処理をするAWS Lambdaを実行してもいいですが、Redmine APIがコール出来ない場合の再処理などを考慮する必要があると思います。

Lambdaは全部Python3.6です。

webフォームからのポストを受けてDynamoDBへ送信するLambda

import logging
import boto3
import traceback
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('contact')
        event['submit_datetime'] = datetime.now().strftime('%Y%m%d%H%M%S')
        table.put_item(Item=event)
    except:
        logger.error(traceback.format_exc())
        raise Exception(traceback.format_exc())

import logging

import boto3

import traceback

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('contact')

event['submit_datetime'] = datetime.now().strftime('%Y%m%d%H%M%S')

table.put_item(Item=event)

except:

logger.error(traceback.format_exc())

raise Exception(traceback.format_exc())

DynamoDBテーブルではsubmit_datetimeをパーティションキーに、フォームから送信されるメールアドレスをソートキーにしています。

DynamoDB Streamから実行されてSQSへキューを送信するLambda

import logging
import boto3
import json
import traceback

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


def lambda_handler(event, context):
    logger.info(event)
    try:
        sqs_url = os.environ['SQS_URL']

        if not ('Records' in event):
            return event

        sqs = boto3.client('sqs')

        records = event['Records']
        for record in records:

            if not ('dynamodb' in record):
                continue

            if not ('NewImage' in record['dynamodb']):
                continue

            contact = record['dynamodb']['NewImage']

            response = sqs.send_message(
                QueueUrl=sqs_url,
                MessageBody=json.dumps(
                    {
                        'contact_name': contact['contact_name']['S'],
                        'mail_address': contact['mail_address']['S'],
                        'contact_detail': contact['contact_detail']['S']
                    }
                )
            )

            logger.info(response)

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

import logging

import boto3

import json

import traceback

logger = logging.getLogger()

logger.setLevel(logging.INFO)

def lambda_handler(event, context):

logger.info(event)

try:

sqs_url = os.environ['SQS_URL']

if not ('Records' in event):

return event

sqs = boto3.client('sqs')

records = event['Records']

for record in records:

if not ('dynamodb' in record):

continue

if not ('NewImage' in record['dynamodb']):

continue

contact = record['dynamodb']['NewImage']

response = sqs.send_message(

QueueUrl=sqs_url,

MessageBody=json.dumps(

{

'contact_name': contact['contact_name']['S'],

'mail_address': contact['mail_address']['S'],

'contact_detail': contact['contact_detail']['S']

}

)

logger.info(response)

except:

logger.error(traceback.format_exc())

raise Exception(traceback.format_exc())

sqsのurlはLambdaの環境変数に入力しておきます。

SQSからキューを受信してRedmine APIをコールしてチケットを作成するLambda

# coding:utf-8

import logging
import boto3
import json
import os
import traceback
from redminelib import Redmine
from base64 import b64decode

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


def lambda_handler(event, context):
    try:
        redmine_url = os.environ['REDMINE_URL']
        enc_key = os.environ['REDMINE_KEY']
        redmine_key = boto3.client('kms').decrypt(CiphertextBlob=b64decode(enc_key))['Plaintext']

        sqs_url = os.environ['SQS_URL']

        sqs = boto3.client('sqs')
        message = sqs.receive_message(
            QueueUrl=sqs_url,
            MaxNumberOfMessages=1
        )
        logger.info(message)

        if not('Messages' in message):
            return

        message_body = json.loads(message['Messages'][0]['Body'])
        logger.info(message_body)

        redmine = Redmine(
            redmine_url,
            key=redmine_key
        )

        issue = redmine.issue.new()
        issue.project_id = 'contact'
        issue.subject = u'{name}様から問い合わせ'.format(
            name=message_body['contact_name']
        )
        issue.description = '{body}\n{mail}'.format(
            body=message_body['contact_detail'].replace(
                'newline',
                '\n'
            ),
            mail=message_body['mail_address']
        )
        issue.save()

        response = sqs.delete_message(
            QueueUrl=sqs_url,
            ReceiptHandle=message['Messages'][0]['ReceiptHandle']
        )
        logger.info(response)

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

# coding:utf-8

import logging

import boto3

import json

import os

import traceback

from redminelib import Redmine

from base64 import b64decode

logger = logging.getLogger()

logger.setLevel(logging.INFO)

def lambda_handler(event, context):

try:

redmine_url = os.environ['REDMINE_URL']

enc_key = os.environ['REDMINE_KEY']

redmine_key = boto3.client('kms').decrypt(CiphertextBlob=b64decode(enc_key))['Plaintext']

sqs_url = os.environ['SQS_URL']

sqs = boto3.client('sqs')

message = sqs.receive_message(

QueueUrl=sqs_url,

MaxNumberOfMessages=1

)

logger.info(message)

if not('Messages' in message):

return

message_body = json.loads(message['Messages'][0]['Body'])

logger.info(message_body)

redmine = Redmine(

redmine_url,

key=redmine_key

)

issue = redmine.issue.new()

issue.project_id = 'contact'

issue.subject = u'{name}様から問い合わせ'.format(

name=message_body['contact_name']

)

issue.description = '{body}\n{mail}'.format(

body=message_body['contact_detail'].replace(

'newline',

'\n'

mail=message_body['mail_address']

)

issue.save()

response = sqs.delete_message(

QueueUrl=sqs_url,

ReceiptHandle=message['Messages'][0]['ReceiptHandle']

)

logger.info(response)

except:

logger.error(traceback.format_exc())

raise Exception(traceback.format_exc())

sqsのurlはLambdaの環境変数に入力しておきます。
RedmineのurlはLambdaの環境変数に入力しておきます。
redmineのAPIキーは登録するプロジェクトにチケットを作成する権限を持っているユーザーのAPIキーを使用します。
redmineのAPIキーは環境変数に入力してKMSで暗号化します。

最後までお読みいただきましてありがとうございました！

「AWS認定資格試験テキスト＆問題集　AWS認定ソリューションアーキテクト - プロフェッショナル改訂第2版」という本を書きました。

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

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

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

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

@yamamanx

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS apigateway, dynamodb, lambda, Redmine, sqs

: Application Load Balancer スティッキーセッションでどれぐらい偏るかを偶然見ました

Amazon Linux2のPHPを7.2から7.3へアップデートしましたでアッ …

: cfn-initでEC2インスタンスにPHPをインストールしWebサーバーを起動する

AWS CloudFormation による Amazon EC2 へのアプリケ …

: Pepperで撮影した写真をAmazon Rekognitionで分析してその結果をPepperがしゃべる ~(1)AWS編~

Pepperの機能を使えるところは使って、何かしたいなあと思ってまして。目(カ …

: Backlogの実績工数をAmazon QuickSightでの可視化 – 仕組み編

Backlogの実績工数をAmazon QuickSightで可視化してわかった …

: EC2 VyOSで/etc/resolv.confを設定しました

EC2でVyOSを起動してSSHで接続して確認していたところ、どうもVyOSから …

: 「X-Tech JAWS 【第2回】~9割のX-Techと1割の優しさで切り拓く未来~」に行ってきました

「X-Tech JAWS 【第2回】~9割のX-Techと1割の優しさで切り拓く …

: Amazon Elasticsearch ServiceにMySQLのデータを投入してkibanaで可視化してみる

MySQLのデータの可視化にAmazon Elasticsearch Servi …

: GoogleForm,GASからAPI Gateway, Lambdaで入力情報をDynamoDBに格納する

vol.26 AWS認定試験テキスト認定クラウドプラクティショナーのデモ(Dyn …

: Aurora Serverless Data APIを有効にしてLambdaからクエリを実行

Aurora Serverless作成 MySQLを作成しました。作成時にDa …

: Cloud9環境を共有した際の環境認証

Cloud9を環境を構築したIAMユーザー以外に共有したとき、その環境から実行す …

PREV: PyCharmにAWS CloudFormationプラグインをインストールして入力補完してみる
NEXT: AlexaにAWSの最新Feedを読み上げてもらう(Lambda Python)

webフォームからの問い合わせをRedmineに自動登録して対応状況を管理する(API Gateway + Lambda)

webフォームからのポストを受けてDynamoDBへ送信するLambda

DynamoDB Streamから実行されてSQSへキューを送信するLambda

SQSからキューを受信してRedmine APIをコールしてチケットを作成するLambda

ad

ad

関連記事