AWS LamdaとSESを利用したメール送信での複数宛先をセットする方法

Question

lambdaを利用してdynamodbから宛先リストを取得し、対象者にメールを送信したいと考えております。※複数のメールではなく、１つのメールで対象者に

宛先を変数にして複数にしたときにエラーが発生しました。

実現したいこと

宛先、ccにそれぞれ複数のアドレスをセットできるようにしたい

発生している問題・エラーメッセージ

Response
{
  "errorType": "InvalidParameterValue",
  "errorMessage": "Illegal address",
  "trace": [
    "InvalidParameterValue: Illegal address",
    "    at Request.extractError (/var/runtime/node_modules/aws-sdk/lib/protocol/query.js:50:29)",
    "    at Request.callListeners (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:106:20)",
    "    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:78:10)",
    "    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/request.js:686:14)",
    "    at Request.transition (/var/runtime/node_modules/aws-sdk/lib/request.js:22:10)",
    "    at AcceptorStateMachine.runTo (/var/runtime/node_modules/aws-sdk/lib/state_machine.js:14:12)",
    "    at /var/runtime/node_modules/aws-sdk/lib/state_machine.js:26:10",
    "    at Request.<anonymous> (/var/runtime/node_modules/aws-sdk/lib/request.js:38:9)",
    "    at Request.<anonymous> (/var/runtime/node_modules/aws-sdk/lib/request.js:688:12)",
    "    at Request.callListeners (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:116:18)"
  ]
}

該当のソースコード

var aws = require('aws-sdk');
var dynamo = new aws.DynamoDB();
var ses = new aws.SES({ region: "ap-northeast-1" });    //SESの認証が取れているリージョンの選択

exports.handler = async (event) => {
    let prm={
        tablename:"sampledb",//テーブル名
        pk_name:"SendLayer",//パーテーションキーの名称
        pk_prm:{S:"To"},//検索パーテーションキーの指定
        sk_name:"UserId",//ソートキーの名称
        sk_prm:{N:"99999"},//検索ソートキーの指定
    };
    let res= await dynamoquery_pksk(prm);
         
    const to_list_num = Object.keys(res).length
    var to_list ="";
    var to_all  ="";
    
    for(var i = 0; i < to_list_num; i++) {
        to_list = '"' +res[i]["UserAddress"]["S"] + '"' + ','
        //to_list = res[i]["UserAddress"]["S"] + ","
        to_all = to_all + to_list
    }
    var email_params = {
        Destination: {
          ToAddresses: [
            to_all
            ],
           CcAddresses: [
            ]
        },
        Message: {
          Body: { //メール本文　\n\で改行コード
            Text: { Data: "株式会社"
         },
          },
    
          Subject: { Data: "発注願い" },    //メール題名
        },
        Source: "sample@example",           //メール送信元アドレス　※ssesの認証が取れているメールアドレスを選択すること.
        };
        console.log(to_all)
        return ses.sendEmail(email_params).promise()
        //return(to_all)
};



function dynamoquery_pksk(obj){
    return new Promise((resolve, reject) => {
        let params = {
            "TableName": obj.tablename,
            "KeyConditionExpression": "#pk_name = :pk_prm and #sk_name < :sk_prm" ,//検索条件 パーテーションキーでのは=のみ
            "ExpressionAttributeNames":{
                "#pk_name": obj.pk_name,
                "#sk_name": obj.sk_name
            },
            "ExpressionAttributeValues": {
                ":pk_prm": obj.pk_prm,
                ":sk_prm": obj.sk_prm,
            }
        };
        dynamo.query(params,function(err, data) {
            if (err) {
                reject(err, err);
            } else {
                resolve(data.Items);
            }
        });
    });
}

試したこと

console.logで出力された値をそのまま、toaddresにセットすると普通に送信できました。
また、to_allではなくto_list(*要は宛先が１つ)の場合は送信できました。

ログの内容

START RequestId: 46b56a5e-125f-4156-ba6b-03b1588f2d0b Version: $LATEST
2022-09-16T08:36:35.975Z	46b56a5e-125f-4156-ba6b-03b1588f2d0b	INFO	to_all
2022-09-16T08:36:35.975Z	46b56a5e-125f-4156-ba6b-03b1588f2d0b	INFO	"[e-mail]","[e-mail]",
2022-09-16T08:36:36.195Z	46b56a5e-125f-4156-ba6b-03b1588f2d0b	ERROR	Invoke Error 	{"errorType":"InvalidParameterValue","errorMessage":"Illegal address","code":"InvalidParameterValue","message":"Illegal address","time":"2022-09-16T08:36:36.137Z","requestId":"dee2cdc7-173a-4308-bd81-d85e8bf5fbc8","statusCode":400,"retryable":false,"retryDelay":54.19076785133659,"stack":["InvalidParameterValue: Illegal address","    at Request.extractError (/var/runtime/node_modules/aws-sdk/lib/protocol/query.js:50:29)","    at Request.callListeners (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:106:20)","    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:78:10)","    at Request.emit (/var/runtime/node_modules/aws-sdk/lib/request.js:686:14)","    at Request.transition (/var/runtime/node_modules/aws-sdk/lib/request.js:22:10)","    at AcceptorStateMachine.runTo (/var/runtime/node_modules/aws-sdk/lib/state_machine.js:14:12)","    at /var/runtime/node_modules/aws-sdk/lib/state_machine.js:26:10","    at Request.<anonymous> (/var/runtime/node_modules/aws-sdk/lib/request.js:38:9)","    at Request.<anonymous> (/var/runtime/node_modules/aws-sdk/lib/request.js:688:12)","    at Request.callListeners (/var/runtime/node_modules/aws-sdk/lib/sequential_executor.js:116:18)"]}
END RequestId: 46b56a5e-125f-4156-ba6b-03b1588f2d0b
REPORT RequestId: 46b56a5e-125f-4156-ba6b-03b1588f2d0b	Duration: 953.65 ms	Billed Duration: 954 ms	Memory Size: 128 MB	Max Memory Used: 82 MB	Init Duration: 427.38 ms

ここにより詳細な情報を記載してください。
エラーの内容をみる限りは、アドレスのセットし方がまちがっているようなのですが、どうすればよいでしょうか？

Answer 1

宛先一覧を作るコードが間違えています
複数のアドレスを1つの文字列として作成していますが、
"[e-mail], [e-mail]"
正しくは
["[e-mail]", "[e-mail]"]
にするのが正しいものとなります

誤

const to_list_num = Object.keys(res).length
var to_list = "";
var to_all = "";

for (var i = 0; i < to_list_num; i++) {
  to_list = '"' + res[i]["UserAddress"]["S"] + '"' + ','
  //to_list = res[i]["UserAddress"]["S"] + ","
  to_all = to_all + to_list
}
var email_params = {
  Destination: {
    ToAddresses: [
      to_all
    ],
    CcAddresses: [
    ]
  },
  Message: {
    Body: { //メール本文　\n\で改行コード
      Text: {
        Data: "株式会社"
      },
    },

    Subject: { Data: "発注願い" },    //メール題名
  },
  Source: "sample@example",
};

正

const to_list_num = Object.keys(res).length
var to_list = "";
var to_all = [];

for (var i = 0; i < to_list_num; i++) {
  to_list = res[i]["UserAddress"]["S"]
  to_all.push(to_list)
}
var email_params = {
  Destination: {
    ToAddresses: to_all,
    CcAddresses: []
  },
  Message: {
    Body: { //メール本文　\n\で改行コード
      Text: {
        Data: "株式会社"
      },
    },

    Subject: { Data: "発注願い" },    //メール題名
  },
  Source: "sample@example",
};

---

また回答とは関係ない個人的なソースコードの指摘ですが、

• varとconstが混在しているので、基本的にはconstで再代入を行う場合はletで宣言し、varを使わないようにしたほうが良いです
• dynamo.queryをしているところでコールバック関数の結果をPromiseで返していますが、SESのように.promiseを使うとよいかと思います
  return dynamo.query(params).promise()
• インデントがズレているので、フォーマットをかけるようにお願いします
• 単純なFor文を回して配列内のオブジェクトを取り出すループの場合は配列のmap関数を使うとキレイに書けるかと思います
• DynamoDBを使うときはaws.DynamoDB()ではなくaws.DynamoDB.DocumentClient()を使う方が扱いやすいデータになります

以下例です

const aws = require('aws-sdk')
const dynamo = new aws.DynamoDB.DocumentClient()
const ses = new aws.SES({ region: "ap-northeast-1" })

exports.handler = async () => {
  const prm = {
    tablename: "sampledb",
    pk_name: "SendLayer",
    pk_prm: "To",
    sk_name: "UserId",
    sk_prm: "99999",
  }
  const res = await dynamoquery_pksk(prm)

  // https://developer.mozilla.org/ja/docs/Web/JavaScript/Reference/Global_Objects/Array/map
  const to_list = res.Items.map(item => item["UserAddress"])

  // https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SES.html#sendEmail-property
  const email_params = {
    Destination: {
      ToAddresses: to_list,
      CcAddresses: []
    },
    Message: {
      Body: {
        Text: {
          Data: "株式会社"
        },
      },

      Subject: { Data: "発注願い" },
    },
    Source: "sample@example",
  }
  console.log(email_params)
  return ses.sendEmail(email_params).promise()
}

function dynamoquery_pksk(obj) {
  // https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB/DocumentClient.html#query-property
  const params = {
    "TableName": obj.tablename,
    "KeyConditionExpression": "#pk_name = :pk_prm and #sk_name < :sk_prm",
    "ExpressionAttributeNames": {
      "#pk_name": obj.pk_name,
      "#sk_name": obj.sk_name
    },
    "ExpressionAttributeValues": {
      ":pk_prm": obj.pk_prm,
      ":sk_prm": obj.sk_prm,
    }
  }
  return dynamo.query(params).promise()
}

JavascriptやAWSの学習は大変かと思いますが頑張ってください

Comments

[shunn]

正しい解答だけでなく、さらに良い方法や改善点をご教示頂きありがとうございました。」

[shunn]

度々申し訳ございません。
実行してみたら、"errorMessage": "One or more parameter values were invalid: Condition parameter type does not match schema type",
というエラーでdbからよみとりができないです。documentclientなどのリファレンスを確認しましたが、必要なパラメータ自体はセットできているきがするのですが、なにか良い方法がありますでしょうか？
情報すくなく申し訳ございません。

[shunn]

一応、aws.config.updateでリージョンもセットしてみました。

[shunn]

UserIDを""でくくっていたため、文字型で認識され、エラーとなったようです。""なくしたらできました。
ありがとうございました。