AWS SESのメール転送をLambdaを使って実現するサンプルソースコード

2020年4月12日2020年7月15日

今回はAmazon SESのメール転送をLambdaを使って実現するためのサンプルソースコードについてご紹介いたします。

AWS SESのメール転送をLambdaを使って実現するサンプルソースコード

AWSのSESのメール転送をネットに落ちている情報を利用してPythonを使って組みました。

Lambdaの構成は次の通りです。

S3の特定のバケットに情報が入ったのをトリガーとして、Lambdaを起動するようにしております。

Lamdbaのセキュリティグループに、S3の全権やSESの全権を設定しなければならず、そこが結構ハマる箇所でした。

モニタリングのCloudWatchを見ながら試行錯誤を繰り返しました。

AWS SESのメール転送をLambdaを使って実現するためのソースコードはこちらです。

# import json

# def lambda_handler(event, context):
#     # TODO implement
#     return {
#         'statusCode': 200,
#         'body': json.dumps('Hello from Lambda!')
#     }

import boto3
import email
import re

ORIGIN_TO  = "送信元のメールアドレス"
FORWARD_TO = "送信先のメールアドレス"
SES_REGION = "SESが設定されているリージョン"
S3_BUCKET  = "SESのメールが保存されるS3のバケット名"

def parse_mail(raw_message):

    replaced_message = raw_message.replace(ORIGIN_TO, FORWARD_TO)
    replaced_message = re.sub("From:.+?\n", "From: %s\r\n" % ORIGIN_TO, replaced_message)
    replaced_message = re.sub("Return-Path:.+?\n", "Return-Path: %s\r\n" % ORIGIN_TO, replaced_message)

    return replaced_message

def send_mail(message):

    ses = boto3.client('ses', region_name=SES_REGION)

    ses.send_raw_email(
        Source = FORWARD_TO,
        Destinations=[
            FORWARD_TO
        ],
        RawMessage={
            'Data': message
        }
    )

def lambda_handler(event, context):
    try:
        s3_key = event['Records'][0]['s3']['object']['key']

        s3 = boto3.client('s3')
        print('## GET EVENT')
        response = s3.get_object(
            Bucket = S3_BUCKET,
            Key    = s3_key
        )
        raw_message = response['Body'].read()
        message = parse_mail(raw_message)
        
        print(message)

        send_mail(message)

    except Exception as e:
        print(e)

# import json

# def lambda_handler(event, context):

# # TODO implement

# return {

# 'statusCode': 200,

# 'body': json.dumps('Hello from Lambda!')

# }

import boto3

import email

import re

ORIGIN_TO = "送信元のメールアドレス"

FORWARD_TO = "送信先のメールアドレス"

SES_REGION = "SESが設定されているリージョン"

S3_BUCKET = "SESのメールが保存されるS3のバケット名"

def parse_mail(raw_message):

replaced_message = raw_message.replace(ORIGIN_TO, FORWARD_TO)

replaced_message = re.sub("From:.+?\n", "From: %s\r\n" % ORIGIN_TO, replaced_message)

replaced_message = re.sub("Return-Path:.+?\n", "Return-Path: %s\r\n" % ORIGIN_TO, replaced_message)

return replaced_message

def send_mail(message):

ses = boto3.client('ses', region_name=SES_REGION)

ses.send_raw_email(

Source = FORWARD_TO,

Destinations=[

FORWARD_TO

RawMessage={

'Data': message

}

)

def lambda_handler(event, context):

try:

s3_key = event['Records'][0]['s3']['object']['key']

s3 = boto3.client('s3')

print('## GET EVENT')

response = s3.get_object(

Bucket = S3_BUCKET,

Key = s3_key

)

raw_message = response['Body'].read()

message = parse_mail(raw_message)

print(message)

send_mail(message)

except Exception as e:

print(e)

print文を挟んでデバッグしながら行いました。
ソースコードを書く以外にも色々セッティングしなければならない箇所があり、単純にソースコードをコピペするだけではうまくいかなかったりします。

作りながら知りましたが、実際のシステムではSESのメール転送をLambdaで使うことは推奨されていないそうです。
他のメールサービスを使った方が良いらしいですね。

終わりに

今回はAmazon SESのメール転送をLambdaを使って実現するためのサンプルソースコードについてご紹介いたしました。

最後までお読みいただきありがとうございます。
よろしければブログやTwitterでのシェアをお願いしております。
コメントもお待ちしております。
誤植や勘違いなどございましたらコメント欄にて教えていただけると幸いです。

ITパスポート、基本情報技術者、応用情報技術者などIPAが提供する国家資格の過去問を学べるモバイルアプリをリリースしました。
詳しくは下記のプレスリリースをご覧ください。
https://prtimes.jp/main/html/rd/p/000000008.000073303.html

Youtubeチャンネル開設いたしました。
チャンネル登録者10,000人を目指しているので、良いと思った方はチャンネル登録をお願いしたいです。
https://www.youtube.com/channel/UC219XhmSRxmXltTy6COxSMw

SES

Posted by ちこ

コロナが本格的に流行る前に名古屋に１泊２日の旅行に行ってきた感想〜Part２〜

AWSのLambdaのメール送信でDuplicate header 'DKIM-Signature'と出たときの対処法

コメント一覧

まだ、コメントがありません