概要

SSLサーバー証明書の更新作業は ACM で解放されたけど、RI は自動更新できないので有効期限の監視をしておかないと、いつの間にか期限が切れてオンデマンド料金を支払う事になってしまう（現になってしまったので、これを作った・・）。
https://aws.amazon.com/jp/premiumsupport/knowledge-center/renew-ri/
EC2 の他に RDS や ElastiCache や Elasticsearch でもリザーブドインスタンスを使っているものがある場合は、まとめてチェックするこちらを使う。
この Lambdaを設定した AWS アカウントの全EC2リザーブドインスタンスの有効期限をチェックして、期限が切れる THRESHOLD 日前になったら Slack へ通知する。
CloudWatch のイベントで１日一回、この Lambda を実行する（更新しない限り、一日一回通知が飛ぶ）
State が active の有効期限をチェックする。

設定

Lambda に付けるロールを作成する

ロールにアタッチするポリシー

AWSLambdaBasicExecutionRole
AWS 管理ポリシー
AmazonEC2DescribeReservedInstance
下記の内容で作成する

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "AmazonEC2DescribeReservedInstance",
            "Effect": "Allow",
            "Action": "ec2:DescribeReservedInstances",
            "Resource": "*"
        }
    ]
}

ロールを作成

ec2-reserved-instance-expiration-date-check
このロールを使用するサービス： Lambda
上記２つのポリシーをアタッチする

Lambda 関数を作成する

関数名
- ec2-reserved-instance-expiration-date-check
ランタイム
- Python 3.7
ロール
- 上で作成した ec2-reserved-instance-expiration-date-check ロール
コード

import os
import boto3
import json
import logging
from pprint import pprint
from datetime import datetime, timedelta, timezone
from urllib.request import Request, urlopen
from urllib.error import URLError, HTTPError

THRESHOLD = int(os.environ['THRESHOLD'])
SLACK_WEBHOOK_URL = os.environ['SLACK_WEBHOOK_URL']
AWS_ACCOUNT_ALIAS = os.environ['AWS_ACCOUNT_ALIAS']

logger = logging.getLogger()
logger.setLevel(logging.INFO)

def lambda_handler(event, context):
    logger.info("Event: " + str(event))

    JST = timezone(timedelta(hours=+9), 'JST')
    now = datetime.now(JST).date()

    RI="EC2"
    client = boto3.client('ec2')
    response = client.describe_reserved_instances()
    for ReservedInstance in response['ReservedInstances']:
      if ReservedInstance['State'] == "active":
        ValidPeriod = (((ReservedInstance['End'].astimezone(JST).date()) - now).days)
        END = str((ReservedInstance['End']).astimezone(JST).date())
        if THRESHOLD > ValidPeriod:
          slack(RI, ReservedInstance['ReservedInstancesId'], ReservedInstance['InstanceType'], str(ReservedInstance['InstanceCount']), str(END), str(ValidPeriod))


def slack(RI, RIID, InstanceType, InstanceCount, End, ValidPeriod):
  color = "warning"
  icon = ":bulb:"
  SlackText=RI + " Reserved Instance Check"
  SlackTextAttachments = "AWS: " + AWS_ACCOUNT_ALIAS + "\n" + "RI ID: " + RIID + "\n" + "Instance Type: " + InstanceType + "\n" + "Instance Count: " + InstanceCount + "\n" + "End: " + End + " (only " + ValidPeriod + " days left)"
  slack_message = {
    'username': "AWS Lambda",
    'text': SlackText,
    'icon_emoji': icon,
    'attachments': [
      {
        "color": color,
        "text": SlackTextAttachments
      }
    ]
  }
  req = Request(SLACK_WEBHOOK_URL, json.dumps(slack_message).encode('utf-8'))
  try:
    response = urlopen(req)
    response.read()
    logger.info("Message posted to %s", SLACK_WEBHOOK_URL)
  except HTTPError as e:
    logger.error("Request failed: %d %s", e.code, e.reason)
  except URLError as e:
    logger.error("Server connection failed: %s", e.reason)

環境変数
- キー：AWS_ACCOUNT_ALIAS
  値：AWSアカウント名
- キー：SLACK_WEBHOOK_URL
  値：SlackのWebhook
- キー：THRESHOLD
  値：40
タイムアウト
- 1分

CloudWatch イベントルール

スケジュール
- Cron式：0 0 * * ? *
ターゲット
- Lambda関数：ec2-reserved-instance-expiration-date-check
ルール名
- reserved_instances_check

Slack通知例