LambdaイベントソースのSNSからCloudWatch Alarm名を取得してみた

LambdaのイベントソースにSNS越しに複数のCloudWatch Alarmがあり、呼び出し元になったCloudWatch Alarm名をLambda側で取得する方法についてのエントリです。呼び出し元になったCloudWatch Alarmによって、Lambdaで処理を分岐させるような事を想定して、CloudWatch Alarm名を取得してみました。

坂巻一義

2018.11.23

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

こんにちは、坂巻です。

構成

100

LambdaでCloudWatch Alarm名を取得することを目的にしているため、CloudWatch Alarmでモニタリングするメトリクスは何でもよかったのですが、今回はStepFunctions（ステートマシン）の正常終了、異常終了ごとにCloudWatch Alarmを作成しました。また、CloudWatch Alarmから、直接Lambdaを起動することはできないのでSNSをかませています。

設定

Lambda関数

SNSイベントからCloudWatch Alarm名を取得する関数として「TestFunction」を作成しました。コードは以下となります。

import json

def lambda_handler(event, context):
    # SNSイベントを取得
    message_unicode = event['Records'][0]['Sns']['Message']
    # 文字列から辞書型に変換
    message_dist = json.loads(message_unicode)
    # CloudWatchAlarm名を取得
    event_sorce_alarm_name = message_dist['AlarmName']

    print(event_sorce_alarm_name)

シンプルなコードですが、SNSイベントからCloudWatch Alarm名を取得する際に、イベントの一部が文字列として扱われており型の問題で少々ハマりました。型変換を行うために、上記コードのハイライト部分の対応が必要でした。詳細については以下をご確認ください。

【Tips】Lambda(Python)でハンドラーのeventを全て辞書型だと思っていたらハマったこと

また、SNSからLambdaに送信されるイベントの内容については、こちらを参考にしました。

Invoking AWS Lambda functions via Amazon SNS

SNS

SNSトピック「TestTopic」を作成しました。サブスクリプションはLambda関数「TestFunction」を呼び出すようになっています。

StepFunctions（ステートマシン）

入力イベントによって、正常終了、異常終了が分岐するステートマシン「TestStateMachin」を作成しました。

定義は以下となります。

{
  "StartAt": "IsSucceed",
  "States": {
    "IsSucceed": {
      "Type": "Choice",
      "Choices": [{
        "Variable": "$.success",
        "StringEquals":"True",
        "Next": "Succeed"
      }],
      "Default": "Fail"
    },
    "Fail": {
      "Type": "Fail"
    },
    "Succeed": {
      "Type": "Succeed"
    }
  }
}