AWSのSESでサンクスメール配信のひな形作ってみた

諸般の事情でAWSのSESを使わないといけなくなっちゃって、検証がてら
いじっていて、結構ややこしかったので備忘録的に手順をまとめておきます。

全体の手順としては以下の様な感じ。SDK組み込んだプログラムからしか
SES送信用のAPIを叩けない様に設定しています。

1.SESの設定
2.SNSから呼び出すLambda作成
3.SNSの設定(BOUNCE対応)
4.DynamoDB作成(BOUNCE対応)
5.SESを使うLambdaの作成
6.Cognitoの設定
7.APIGateway設定
8.フロントプログラムの準備
9.SESのBOUNCE設定

◆作業手順(やや省略)

1.SES設定

先人が色々とまとめてくださっているので割愛、東京で使えるようになったので
東京リージョンで設定したほうが色々と楽です。
注意点としてはsandboxの解除申請を行うこと。これを忘れていると外部にメール
送信できません。

2.SNSから呼び出すLambda作成

BOUNCE時にBOUNCEになったメールアドレスをDynamoDBに登録する
Lambdaを準備します。

import datetime
import json
import os
import boto3

BOUNCE_TABLE = os.getenv('TABLE_NAME')
dynamodb = boto3.resource('dynamodb')

def lambda_handler(event, context):
  try:
    table    = dynamodb.Table(BOUNCE_TABLE)
    msg = event['Records'][0]['Sns']['Message']
    b = json.loads(msg)
    bounce_type = b['bounce']['bounceType']
    bounce_mail = b['bounce']['bouncedRecipients'][0]['emailAddress']

    if bounce_type == 'Permanent':
       createdate = datetime.datetime.now()
       r = table.put_item(
           Item = {
                   'email': bounce_mail,
                   'createdate':str(createdate)
           }
       )
    return r
  except Exception as e:
    print(e)
    raise e

3.SNSの設定

・トピックを作成します。

・トピックを作成してからサブスクリプションを作成します。

・プロトコルにLambdaを選択してエンドポイントを選択します。

4.DynamoDB作成

[email]項目をキーとしたDynamoDBのテーブルを作成します。
DynamoDBのテーブル作成方法は適当にググれば出てくるので
そちらをご参照ください。

5.SESを使うLambdaの作成

SESからメール送信するLambdaを作成します。

import boto3
import json
import os

SRC_MAIL = os.getenv('FROM_ADDR')
REGION = os.getenv('SES_REGION')
BUCKET = os.getenv('BUCKET_NAME')
BOUNCE_TABLE = os.getenv('TABLE_NAME')

def exist_email(mail_addr):
  """
  Send Mail Check
  """
  try:
      result = 'notexist'
      dynamodb = boto3.resource('dynamodb')
      table    = dynamodb.Table(BOUNCE_TABLE)
      em = table.get_item(
                Key={
                     'email':mail_addr
                }
      )
      if ('Item' in em):
         result = 'exist'
      return result
  except Exception as e:
    print(e)
    raise e

def get_template(file_name):
  """
  S3 get mailbody
  """
  try:
      s3_cl = boto3.client('s3')
      response = s3_cl.get_object(Bucket=BUCKET, Key=file_name)
      template_data = response['Body'].read()
      return template_data    
  except Exception as e:
    print(e)
    raise e

def send_email(source, to, subject, body):
  """
  SES send email
  """
  try:
      client = boto3.client('ses', region_name=REGION)
      response = client.send_email(
          Source=source,
          Destination={
              'ToAddresses': [
                  to,
              ]
          },
          Message={
              'Subject': {
                  'Data': subject,
              },
              'Body': {
                  'Text': {
                      'Data': body,
                  },
              }
          }
      )
      return response
  except Exception as e:
    print(e)
    raise e

def lambda_handler(event, context):
  try:
      data = event["body-json"]
      tomail = data['email']
      fn = data['template'] +'.txt'
      subject = "Test Send Mail"
      template = get_template(fn)
      message = template.decode('utf-8')
      mc = exist_email(tomail)
      if mc == 'notexist':
         r = send_email(SRC_MAIL, tomail, subject, message)
      else:
         r = {
               'statusCode': 500,
               'body': json.dumps('Bounce Mail exist')
         }
      return r
  except Exception as e:
    print(e)
    raise e

6.Cognitoの設定

・IDプールを作成します。

・新しいIDプールの作成をクリックします

・IDプール名を入力し、[認証されていないID・・・]にチェックを入れます。

・確認画面が表示されるので[許可]をクリックします。

・サンプルコードの箇所で[IdentityPoolId]を確認し[ダッシュボードに移動]をクリックします。

・IAMメニューに移動しロールにて「Cognito_XXXXUnauth_Role」を探してポリシーをアタッチします。

・[APIGatewayInvokeFullAccess]をアタッチします。
*本来はセキュリティを考慮してAPIを限定して設定すべきです。

7.APIGateway設定

通常通りAPIを作成してやります。今回はPOSTで作成しました。
・CORS設定してやります。

・メソッドリクエストで認可の箇所で[AWS_IAM]を選択します。

・統合リクエストにて「マッピングテンプレート」を設定します。

・「application/JSON」を追加して以下のパラメータを入力、保存します。

{

   "body-json" : $input.json('$')

}

・フォーマットチェック用にモデルを作成します。

・モデルのスキーマに以下の様に入力し、作成します。

{
    "title": "sendEmail",
    "type": "object",
    "properties": {
        "email": {
            "type": "string"
        },
        "template": {
            "type": "string"
        }
    },
    "required": ["email", "template"]
}

・メソッドリクエストで「リクエストの検証」で[本文の検証]を選択し、「リクエスト本文」にて「コンテンツタイプ」で[application/JSON]を入力後に[モデル名]で作成したモデルを選択します。

8.フロントプログラムの準備

・APIGatewayでSDKを生成しダウンロードします。

・ダウンロードしたフォルダにフロント用のHTMLを作成します。

<!DOCTYPE html>
<html lang="ja">
<head>
  <meta charset="utf-8">
  <meta name="viewport" content="width=device-width,initial-scale=1.0">
  <title>API test</title>
  <!-- AWS SDK -->
  <script src="https://sdk.amazonaws.com/js/aws-sdk-2.7.19.min.js"></script>
  <!-- jQuery -->
  <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.11.3/jquery.min.js"></script>
  <!-- API用SDK -->
  <script type="text/javascript" src="lib/axios/dist/axios.standalone.js"></script>
  <script type="text/javascript" src="lib/CryptoJS/rollups/hmac-sha256.js"></script>
  <script type="text/javascript" src="lib/CryptoJS/rollups/sha256.js"></script>
  <script type="text/javascript" src="lib/CryptoJS/components/hmac.js"></script>
  <script type="text/javascript" src="lib/CryptoJS/components/enc-base64.js"></script>
  <script type="text/javascript" src="lib/url-template/url-template.js"></script>
  <script type="text/javascript" src="lib/apiGatewayCore/sigV4Client.js"></script>
  <script type="text/javascript" src="lib/apiGatewayCore/apiGatewayClient.js"></script>
  <script type="text/javascript" src="lib/apiGatewayCore/simpleHttpClient.js"></script>
  <script type="text/javascript" src="lib/apiGatewayCore/utils.js"></script>
  <script type="text/javascript" src="apigClient.js"></script>
</head>
<body>
<!-- HTML  -->
<input type="text" name="mail" placeholder="メールアドレスを入力"/><br>
<input type="text" name="templateNO" placeholder="メールテンプレート番号を入力"/><br>
<button id="btn">ボタン</button>
<!-- Other Script -->
<script type="text/javascript">
var apigClient;
$(function(){
  //AWS Credentialの初期化
  AWS.config.region = 'ap-northeast-1';
  AWS.config.credentials = new AWS.CognitoIdentityCredentials({
      IdentityPoolId: 'ap-northeast-1:XXXXXXX' //Identity Pool Idを貼り付ける(ARNではない。)
  });
  AWS.config.credentials.get(function(err){
    if(!err){
      //API ClientにaccessKey,secretKey,sessionToken,regionを設定し、初期化します。
      apigClient = apigClientFactory.newClient({
        accessKey: AWS.config.credentials.accessKeyId,
        secretKey: AWS.config.credentials.secretAccessKey,
        sessionToken: AWS.config.credentials.sessionToken,
        region: 'ap-northeast-1'//大事
      });
    }else{
      console.log(err);
    }
  });
});
$('#btn').click(function(){
  var email = $('input[name="mail"]').val();
  var template = $('input[name="templateNO"]').val();
  apigClient.rootPost({},{"email":email, "template":template},{})
  .then(function(result){
    // Add success callback code here.
    console.log(result);
  }).catch( function(result){
    // Add error callback code here.
    console.log(result);
  });
});
</script>
</body>
</html>

9.SESのBOUNCE設定

・SESの「Notifications」から[EditConfiguration]をクリックします。

・Bouncesの箇所でSNSに設定したトピックを選択します。
＊必要に応じてCompliantsとDeliveriesも設定します。

なかなか大変ですが、一度やれば何とか流れは押さえられます。APIGatewayからエラーだろうが何だろうが200を返してくるのでエラー時はきちんと500で返す設定をしたり
Cloudwatchにもメトリクス設定したり、BOUNCE時のメールの取り扱いなど細かい運用周りで決めないといけないことは非常に多そうですね。

◆参照サイト

危うく3日坊主になりそうでした。とりあえず今日は「IS-LM分析」です。テキストでは簡便4象限法とかいうのの説明が多いです。なのでさっぱりわけわからん状態ですが、それなりに頑張ってみます。 1: IS曲線の導出財市場の均衡を表す。Iは投資を表し、Sは貯蓄を表す。・IS曲線導出の材料 I→利子率の関数、S→所得の関数で「I=S」で財市場を表す。・投資関数利子率の減少関数、I (投資関数)=I(r)　※rは利子率・政府活動の導入裁量的な拡張的な財政政策はIS曲線をシフトさせる。 IS曲線の右シフト=政府支出の増大や減税等の有効需要を増加させる要因による 2: LM曲線の導出利子率の低下が国民所得の増大につながる因果関係を明らかにする目的・LM曲線導出の材料貨幣需要(MD)=L、L=取引的動機+予備的動機(L1)+投機的動機(L2) MD=L1+L2 貨幣供給(Ms)=名目貨幣供給/物価(P) ・LM曲線のシフト金融緩和策・物価下落：実質貨幣供給(MS)が増大→右(下)へシフト金融引締策・物価上昇：実質貨幣供給(MS)が減少→左(上)へシフト独立投資拡大→IS曲線が右にシフト利子率がr1→r2に下落する。 IS曲線、LM曲線の均衡点がE→Fに移動する。国民所得がY1→Yfとなって増大する。 3:特殊なLM曲線・流動性の罠のLM曲線金融政策は無効→LM曲線をシフトさせても均衡点Eは変わらない IS曲線を右にシフトさせる拡張的な財政政策を実施すると均衡点が E→E´となり国民所得がY1→Y2に増加するので財政政策は有効となる。　　　・投資の利子率に対する弾力性ゼロ金融政策は無効→LM曲線を右にシフトさせても国民所得が増えない。流動性の罠と同じくIS曲線を右にシフトさせる拡張的な財政政策を実施すると均衡点がE→E´となり国民所得がY1→Y2に増加するので財政政策は有効となる。　　　　　　 4: クラウディング・アウト政府が市場に介入して公共投資を行うと民間の投資が締出しを受ける・古典派による財政政策の無効論政府支出を拡大すると利子率が上昇してしまい。投資が減少する。政府の支出がクラウディングアウトを引き起こして支...

このブログを検索

アラフィフおやじログ