Lambda 関数を利用してスポットプレイスメントスコア結果を SNS で通知してみた

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": "lambda.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
        }
    ]
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "logs:CreateLogGroup",
            "Resource": "*"
        },
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": [
                "*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": "ec2:GetSpotPlacementScores",
            "Resource": "*"
        },
        {
            "Effect": "Allow",
            "Action": "sns:Publish",
            "Resource": "arn:aws:sns:ap-northeast-1:123456789012:aaaaa-xxxxx"
        }
    ]
}

import boto3
import json
import os

def lambda_handler(event, context):
    # EC2クライアントとSNSクライアントを作成
    ec2_client = boto3.client('ec2')
    sns_client = boto3.client('sns')

    # SNSトピックARN、インスタンスタイプ、リージョン名を環境変数から取得
    sns_topic_arn = os.environ['SNS_TOPIC_ARN']
    instance_type = os.environ['INSTANCE_TYPE']
    region_names = os.environ['REGION_NAMES'].split(',')  # カンマで区切られたリージョン名をリストに変換

    # ターゲット容量とターゲット容量の単位を設定
    target_capacity = 5
    target_capacity_unit_type = 'vcpu'

    try:
        # スポットプレイスメントスコアを取得
        response = ec2_client.get_spot_placement_scores(
            InstanceTypes=[instance_type],
            TargetCapacity=target_capacity,
            TargetCapacityUnitType=target_capacity_unit_type,
            MaxResults=10,
            RegionNames=region_names,
            SingleAvailabilityZone=True  # アベイラビリティゾーンごとのスコアを取得
        )

        # 結果を取得
        spot_scores = response.get('SpotPlacementScores', [])
        results = []

        for score in spot_scores:
            results.append({
                'AvailabilityZoneId': score.get('AvailabilityZoneId', 'No AvailabilityZoneId available'),
                'Score': score.get('Score', 'No Score available')
            })

        # SNS通知のサブジェクトを環境変数に基づいて設定
        subject = f'Spot Placement Scores for {instance_type}'

        # 結果をSNSトピックに通知
        message = json.dumps(results, indent=2)
        sns_client.publish(
            TopicArn=sns_topic_arn,
            Subject=subject,
            Message=message
        )

        # 結果をログに出力
        print(message)

        return {
            'statusCode': 200,
            'body': message
        }

    except Exception as e:
        print(f"Error: {str(e)}")
        return {
            'statusCode': 500,
            'body': json.dumps(f"Internal server error: {str(e)}")
        }

Spot Placement Scores for t1.micro

[
  {
    "AvailabilityZoneId": "apne1-az1",
    "Score": 3
  },
  {
    "AvailabilityZoneId": "usw2-az2",
    "Score": 3
  },
  {
    "AvailabilityZoneId": "usw2-az3",
    "Score": 3
  },
  {
    "AvailabilityZoneId": "usw2-az1",
    "Score": 3
  },
  {
    "AvailabilityZoneId": "apne1-az4",
    "Score": 3
  }
]

--
If you wish to stop receiving notifications from this topic, please click or visit the link below to unsubscribe:
https://sns.ap-northeast-1.amazonaws.com/unsubscribe.html?SubscriptionArn=arn:aws:sns:ap-northeast-1:123456789012:aaaaa-xxxxx:7ede8eb1-aaaa-1111-bbbb-1234de098765&[email protected]

Please do not reply directly to this email. If you have any questions or comments regarding this email, please contact us at https://aws.amazon.com/support