YAZエンジニアが運営するメディア

この記事でできること

• CloudWatchの基本的な役割を理解する
• EC2のCPU使用率を監視する
• CPU使用率がしきい値を超えた際にメール通知を送る
• CloudWatch Agentを使ってApacheのエラーログを監視する
• アラートメールを日本語化する仕組みを理解する

ポイント

CloudWatchは「監視」、CloudWatch Alarmは「条件の判定」、 SNSは「通知」を担当します。

設定内容

タイプ：Standard
トピック名：ojt-sns-topic-[名前]-01

注意

メールアドレスを登録しただけでは通知を受信できません。 必ず確認メールからサブスクリプションを承認してください。

注意

&を付けて実行した処理はバックグラウンドで動作します。 動作確認が完了したら、必ず停止コマンドを実行してください。

CloudWatch Agentとは？

EC2内のログなどを収集し、 CloudWatchへ送信するためのソフトウェアです。

設定内容

ロール名：ojt-ec2-roll-[名前]-01
ポリシー：CloudWatchAgentServerPolicy
ポリシー：AmazonSSMManagedInstanceCore

{
  "agent": {
    "metrics_collection_interval": 60,
    "run_as_user": "root"
  },
  "logs": {
    "logs_collected": {
      "files": {
        "collect_list": [
          {
            "file_path": "/var/log/httpd/access_log",
            "log_group_name": "ojt-apache-accesslog-fujita-01",
            "log_stream_name": "fujita",
            "retention_in_days": 7
          },
          {
            "file_path": "/var/log/httpd/error_log",
            "log_group_name": "ojt-apache-error-log-fujita-01",
            "log_stream_name": "fujita",
            "retention_in_days": 7
          }
        ]
      }
    }
  }
}

主な設定内容

• metrics_collection_interval：Agentの収集間隔を60秒に設定します。
• run_as_user：CloudWatch Agentをrootユーザーとして動かします。
• file_path：収集対象となるApacheログの保存場所です。
• log_group_name：CloudWatch Logsに作成するロググループ名です。
• log_stream_name：ログストリーム名です。
• retention_in_days：ログの保存期間を7日間に設定します。

自分の環境に合わせて変更する箇所

log_group_nameとlog_stream_nameは、 自分の名前や命名規則に合わせて変更してください。 また、Apacheのログファイルが別の場所にある場合は、file_pathも変更します。

主な設定値

ドキュメント名：AmazonCloudWatch-ManageAgent
Action：configure
Mode：ec2
Configuration Source：ssm
Configuration Location：AmazonCloudWatch-linux
Restart：yes

ポイント

ログ内でerrorに一致するイベントが発生した際に、 メトリクス値として1を記録します。 そのメトリクスをCloudWatch Alarmで監視します。

補足

viでログファイルを直接編集する方法もありますが、 初心者向けの記事では、ログの末尾へ追記できる tee -aを使用しています。

Lambdaで整形する主な情報

• アラーム名
• アラームが発生した時刻
• 監視対象
• アラームが発生した理由
• 現在のアラーム状態

import os
from datetime import datetime, timedelta, timezone

import boto3


sns = boto3.client("sns")
SNS_TOPIC_ARN = os.environ["SNS_TOPIC_ARN"]


def lambda_handler(event, context):
    """
    CloudWatch Alarmの状態変化を受け取り、
    必要な情報を日本語に整形してSNSへ送信する。
    """

    alarm_data = event.get("alarmData", {})
    state = alarm_data.get("state", {})
    configuration = alarm_data.get("configuration", {})

    alarm_name = alarm_data.get("alarmName", "取得できませんでした")
    state_value = state.get("value", "UNKNOWN")
    reason = state.get("reason", "取得できませんでした")
    occurred_at = state.get("timestamp") or event.get("time", "")

    region = event.get("region", "取得できませんでした")
    account_id = event.get("accountId", "取得できませんでした")
    alarm_arn = event.get("alarmArn", "取得できませんでした")

    target = get_monitoring_target(configuration)
    occurred_at_jst = convert_to_jst(occurred_at)

    state_ja = {
        "ALARM": "アラーム状態",
        "OK": "正常",
        "INSUFFICIENT_DATA": "データ不足",
    }.get(state_value, state_value)

    subject = f"【CloudWatch】{alarm_name}：{state_ja}"

    message = f"""CloudWatchアラームの状態が変化しました。

■ アラーム名
{alarm_name}

■ 現在の状態
{state_ja}（{state_value}）

■ 発生時刻
{occurred_at_jst}

■ 監視対象
{target}

■ 発生理由
{reason}

■ AWSリージョン
{region}

■ AWSアカウントID
{account_id}

■ アラームARN
{alarm_arn}

AWSマネジメントコンソールで詳細を確認してください。
"""

    response = sns.publish(
        TopicArn=SNS_TOPIC_ARN,
        Subject=subject[:100],
        Message=message,
    )

    print(f"SNSへの送信に成功しました: {response['MessageId']}")

    return {
        "statusCode": 200,
        "message": "日本語のアラート通知を送信しました。",
    }


def get_monitoring_target(configuration):
    """アラーム設定から監視対象のメトリクスとディメンションを取得する。"""

    metrics = configuration.get("metrics", [])

    if not metrics:
        return "取得できませんでした"

    metric_stat = metrics[0].get("metricStat", {})
    metric = metric_stat.get("metric", {})

    namespace = metric.get("namespace", "不明")
    metric_name = metric.get("name", "不明")
    dimensions = metric.get("dimensions", {})

    dimension_text = ", ".join(
        f"{key}={value}" for key, value in dimensions.items()
    )

    if dimension_text:
        return f"{namespace} / {metric_name} / {dimension_text}"

    return f"{namespace} / {metric_name}"


def convert_to_jst(timestamp_text):
    """CloudWatchから受け取った時刻を日本時間へ変換する。"""

    if not timestamp_text:
        return "取得できませんでした"

    try:
        normalized = timestamp_text.replace("Z", "+00:00")

        if (
            len(normalized) >= 5
            and normalized[-5] in ("+", "-")
            and normalized[-3] != ":"
        ):
            normalized = normalized[:-2] + ":" + normalized[-2:]

        timestamp = datetime.fromisoformat(normalized)
        jst = timezone(timedelta(hours=9))

        return timestamp.astimezone(jst).strftime(
            "%Y年%m月%d日 %H時%M分%S秒"
        )

    except ValueError:
        return timestamp_text

コードの主な処理

• CloudWatch Alarmからアラーム名・状態・発生理由・発生時刻を取得します。
• 発生時刻を日本時間へ変換します。
• アラーム状態を「正常」「アラーム状態」「データ不足」の日本語へ変換します。
• 監視対象のメトリクスやEC2インスタンスIDを取得します。
• 日本語へ整形した内容をSNSトピックへ送信します。

環境変数

キー：SNS_TOPIC_ARN
値：通知先として使用するSNSトピックのARN

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "sns:Publish",
      "Resource": "通知先SNSトピックのARN"
    }
  ]
}

ポイント

Resourceには、環境変数SNS_TOPIC_ARNへ設定したものと同じSNSトピックのARNを指定します。

今回実施した内容

• CloudWatchによるEC2のCPU使用率の監視
• CloudWatch Alarmによるしきい値の判定
• SNSを利用したメール通知
• CloudWatch Agentを利用したApacheログの監視
• メトリクスフィルターを利用したログアラームの作成
• Lambdaを利用したアラートメールの日本語化

CloudWatchを活用すると、AWSリソースやログの異常を早期に発見できます。 初めて設定する場合は、まずCPU使用率の監視から始め、 その後にログ監視や通知内容のカスタマイズへ進むと理解しやすくなります。