【AWS】Lambda + Dynamodb + SQS + SESでメールを送信する

import json
import urllib.parse
import boto3
from boto3.dynamodb.conditions import Key, Attr

def lambda_handler (event, context):
    # 1. DynamoDBのmailaddressテーブルを操作するオブジェクト
    dynamodb = boto3.resource('dynamodb')
    table = dynamodb.Table('mailaddress')
    # 2. SQSのキューを操作するオブジェクト
    sqs = boto3.resource('sqs')
    queue= sqs.get_queue_by_name (QueueName='mailsendqueue0000001')
    for rec in event['Records']:
        # 3. S3に置かれたファイルパスを取得
        bucketname= rec['s3']['bucket']['name']
        filename= rec['s3']['object']['key']
        # 4. haserrorが0のものをmailaddressテーブルから取得
        response = table.query(
            IndexName='haserror-index',
            KeyConditionExpression=Key('haserror').eq(0)
        )
        # 5. 上記の1件1件についてループ処理
        for item in response['Items']:
            # 6. 送信済みを示すissendを0にする
            table.update_item(
                Key={'email': item['email']},
                UpdateExpression="set issend=:val",
                ExpressionAttributeValues= {
                    ':val': 0
                }
            )
            # 7. SQS にメッセージとして登録する
            sqsresponse = queue.send_message(
                MessageBody=item['email'],
                MessageAttributes={
                    'username': {
                        'DataType': 'String',
                        'StringValue': item['username']
                    },
                    'bucketname': {
                        'DataType': 'String',
                        'StringValue': bucketname
                    },
                    'filename': {
                        'DataType': 'String',
                        'StringValue': filename
                    }
                }
            )
            # 結果をログに出力しておく
            print(json.dumps(sqsresponse))

import json
import boto3

sqs = boto3.resource('sqs')
s3 = boto3.resource('s3')
dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('mailaddress')
client = boto3.client('ses')
MAILFROM = 'SESでverified済のメールアドレス' # メールアドレスの変更

def lambda_handler (event, context):
    print(event)
    for rec in event['Records']:
        email = rec['body']
        bucketname = rec['messageAttributes']['bucketname']['stringValue']
        filename = rec ['messageAttributes']['filename']['stringValue']
        username = rec['messageAttributes']['username']['stringValue']

        #S3バケットから本文を取得する
        obj = s3.Object(bucketname, filename)
        response = obj.get()
        maildata = response['Body'].read().decode('utf-8')
        data = maildata.split("\n", 3)
        subject = data[0]
        body= data[2]
        # 送信済みでないことを確認し、また、送信済みに設定する
        response = table.update_item(
            Key = {
                'email': email
            },
            UpdateExpression = "set issend=:val",
            ExpressionAttributeValues = {
                ':val': 1
            },
            ReturnValues = 'UPDATED_OLD'
        )
        #未送信なら送信
        if response['Attributes']['issend'] == 0:
            #メール送信
            response = client.send_email(
                Source=MAILFROM,
                ReplyToAddresses=[MAILFROM],
                Destination= {
                    'ToAddresses': [
                        email
                    ]
                },
                Message={
                    'Subject': {
                        'Data': subject,
                        'Charset': 'UTF-8'
                    },
                    'Body': {
                        'Text': {
                            'Data': body,
                            'Charset': 'UTF-8'
                        }
                    }
                }
            )

        else:
            print("Resend Skip")