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認定クラウドプラクティショナー改訂第3版」という本を書きました。

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

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

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

@yamamanx

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

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

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

- AWS apigateway, dynamodb, lambda, Redmine, sqs

: Amazon EC2 Auto ScalingのVPCは変更できる

EC2 Auto ScalingのVPCは変更できたっけ？？と思いまして試しまし …

: AWS認定ソリューションアーキテクトアソシエイトのサンプル問題

AWS認定ソリューションアーキテクトアソシエイトのサンプル問題の解説を会社のブロ …

: EC2 Instance Connect エンドポイントの作成

このブログのSystems Managerは機能としてセッションマネージャーしか …

: EC2 Windows インスタンス PowerShellでメタデータを見る

Linuxインスタンスならcurlコマンドで確認すればいいのですが、Window …

: Amazon Connect 発信イベントをEventBridgeで確認

Amazon Connectから発信した電話に出たのか、出なかったのかを確認した …

: AWS Transfer Family EFS向けのSFTP対応サーバー

EFSファイルシステムは作成済です。 AWS Transfer Family S …

: AWS Lambda(Python)でDynamoDB テーブルを日次で削除/作成(オートスケーリング付き)

この記事はAWS #2 Advent Calendar 2018に参加した記事で …

: 「関西AWSスタートアップ勉強会」に行ってきました

第2回関西スタートアップAWS勉強会に行ってきました。 akippa 拠点数コ …

: EC2インスタンスを必要最小限のパラメータでCLIとSDKから起動する

EC2インスタンスをCLIとSDKから起動するデモで、パラメータを必要最小限にし …

: AWS Well-Architected フレームワークによるクラウドベストプラクティスのセッションを聞いたので自アカウントの環境を確認してみる

AWS Summit Tokyo 2017で「AWS Well-Architec …

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

関連記事