EventBridge＋SNSで、EC2インスタンスの再起動を検知し、通知メールをカスタマイズする方法

{
  "account": "$.account",
  "instanceId": "$.detail.requestParameters.instancesSet.items[0].instanceId",
  "time": "$.time"
}

"EC2インスタンスの再起動を検知しました。詳細情報を確認の上、適切に対処してください。"
"【詳細情報】"
"AWSアカウント：<account>"
"インスタンスID：<instanceId>"
"再起動時刻：<time>"

const { EC2Client, DescribeInstancesCommand } = require("@aws-sdk/client-ec2");
const { SNSClient, PublishCommand } = require("@aws-sdk/client-sns");

const ec2Client = new EC2Client();
const snsClient = new SNSClient();

exports.handler = async (event) => {
  try {
    console.log("Received event:", JSON.stringify(event, null, 2));

    // CloudTrailイベントからインスタンスIDを抽出
    const instanceIds =
      event.detail.requestParameters?.instancesSet?.items?.map(
        (item) => item.instanceId
      );

    if (!instanceIds || instanceIds.length === 0) {
      throw new Error("No instance IDs found in the event");
    }

    // 最初のインスタンスIDを使用
    const instanceId = instanceIds[0];

    // インスタンスの詳細情報を取得
    const describeParams = {
      InstanceIds: [instanceId],
    };
    const describeCommand = new DescribeInstancesCommand(describeParams);
    const describeResponse = await ec2Client.send(describeCommand);

    // インスタンス名（Nameタグ）を取得
    const instanceName =
      describeResponse.Reservations[0].Instances[0].Tags.find(
        (tag) => tag.Key === "Name"
      )?.Value || "N/A";

    // 現在の日時を取得
    const currentDateTime = new Date().toLocaleString("ja-JP", {
      year: "numeric",
      month: "2-digit",
      day: "2-digit",
      hour: "2-digit",
      minute: "2-digit",
      second: "2-digit",
      timeZone: "Asia/Tokyo",
    });

    // カスタマイズした件名とメッセージ
    const subject = `[AWS通知] インスタンス再起動のお知らせ - ${instanceName}/${instanceId}`;
    const message = `AWSインスタンス ${instanceName}/${instanceId} の再起動が予定されています。
    インスタンス名/ID： ${instanceName}/${instanceId}
    再起動予定日時: ${currentDateTime}
    以上`;

    // SNSトピックのARN（環境変数から取得）
    const topicArn = process.env.SNS_TOPIC_ARN;

    // SNSメッセージ送信
    const publishParams = {
      Message: message,
      Subject: subject,
      TopicArn: topicArn,
    };
    const publishCommand = new PublishCommand(publishParams);
    const response = await snsClient.send(publishCommand);

    console.log("SNS通知送信成功:", response);
    return response;
  } catch (error) {
    console.error("エラーが発生しました:", error);
    throw error;
  }
};