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認定資格試験テキスト　AWS認定AIプラクティショナー」という本を書きました。

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

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

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

@yamamanx

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

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

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

- AWS apigateway, dynamodb, lambda, Redmine, sqs

: ちょっとしたCLI作業にEC2起動テンプレート

CLIでちょっとした作業したいだけのときに、Cloud9を使うまでもないなあと思 …

: kintoneでEveryoneに権限が設定されているアプリをAWS Lambdaで一括チェックする

こないだ、kintone Cafeでユーザーが自由に作成している環境だと、どんな …

: WordPressをAmazon CloudFrontで配信してついでにACM(AWS Certificate Manager)を使って常時SSL化する

当サイトの500と502の発生状況がドイヒーであるとの苦情をいただきまして、Am …

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

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

: 特定AWSアカウント特定リージョンのCloudFormationスタックを削除するLambda(Python)

やりたいこと特定アカウント内特定リージョン内のCloudFormationスタ …

: Amazon InspectorによるLambda関数の脆弱性検出結果を確認しました

AWS re:Invent 2022期間内に発表されましたAmazon Insp …

: Amazon Aurora Serverless 課金確認

Amazon Aurora Serverlessを使い始めてみましたの記事で書い …

: AWS Toolkit for Eclipseをセットアップする

AWSでそろそろ課金がされつつありますので、夜中はインスタンスを自動停止して朝自 …

: Amazon LinuxにAlfresco Community Editionをインストールする

ダウンロード準備 Alfresco公式サイトで、「エンタープライズコンテンツ管理 …

: AWS Firewall Managerを設定して結果を確認

CloudFront対応のポリシーとして作成したかったので、Globalを選択し …

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

関連記事