概要
-
SSLサーバー証明書の更新作業は ACM で解放されたけど、RI は自動更新できないので有効期限の監視をしておかないと、いつの間にか期限が切れてオンデマンド料金を支払う事になってしまう。（現になってしまったので、これを作った・・）
ちなみに、EC2は日時指定で購入予約ができるようになったみたい。 -
AWS Cost Explorer でも有効期限切れアラートを設定できるが、メールにしか送信できなそう。（今後、Chatbotと連携して Slack へも送信できるようになることを期待）
-
EC2 だけのリザーブドインスタンスの有効期限チェックは作ったけど、他にもリザーブドインスタンスをAWSサービスがあるので、それらをまとめてチェックできるようにした。
-
CloudWatch のイベントで１日一回、有効期限監視 Lambda を実行して、有効期限の残り日数が次の THRESHOLD 日になったら Slack へ通知する。
-
残り日数が 10日
-
残り日数が 1日
-
リザーブドインスタンスの状態が active になっているものをチェックし続けるため、有効期限が切れる前に更新（同じリザーブドインスタンスを新規に購入）したとしても、状態が retired になるまでチェックを続けてSlackへ送信する。
設定
Lambda に付けるロールを作成する
ロールにアタッチするポリシー
-
AWSLambdaBasicExecutionRole
-
AWS 管理ポリシー
-
DescribeReservedInstances
-
下記の内容で作成する
{
"Version": "2012-10-17",
"Statement": [
{
"Sid": "DescribeReservedInstances",
"Effect": "Allow",
"Action": [
"es:DescribeReservedElasticsearchInstances",
"rds:DescribeReservedDBInstances",
"elasticache:DescribeReservedCacheNodes",
"ec2:DescribeReservedInstances"
],
"Resource": "*"
}
]
}
ロールを作成
- reserved_instances_check
- このロールを使用するサービス： Lambda
- 上記２つのポリシーをアタッチする
Lambda 関数を作成する
-
関数名
- reserved_instances_check
-
ランタイム
- Python 3.7
-
ロール
- 上で作成した reserved_instances_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
THRESHOLD10 = int(os.environ['THRESHOLD10'])
THRESHOLD1 = int(os.environ['THRESHOLD1'])
SLACK_WEBHOOK_URL = os.environ['SLACK_WEBHOOK_URL']
AWS_ACCOUNT_ALIAS = os.environ['AWS_ACCOUNT_ALIAS']
logger = logging.getLogger()
logger.setLevel(logging.INFO)
JST = timezone(timedelta(hours=+9), 'JST')
now = datetime.now(JST).date()
def lambda_handler(event, context):
logger.info("Event: " + str(event))
ec2_reserved_instance_expiration_date_check()
rds_reserved_instance_expiration_date_check()
elasticache_reserved_instance_expiration_date_check()
es_reserved_instance_expiration_date_check()
def validcheck(RI, RIID, InstanceType, InstanceCount, End, ValidPeriod):
if THRESHOLD10 == ValidPeriod:
slack(RI, RIID, InstanceType, str(InstanceCount), End, str(ValidPeriod))
elif THRESHOLD1 == ValidPeriod:
slack(RI, RIID, InstanceType, str(InstanceCount), 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': "reserved-instance-expiration-data-checker",
'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)
def ec2_reserved_instance_expiration_date_check():
RI="EC2"
client = boto3.client('ec2')
responce = client.describe_reserved_instances()
for ReservedInstance in responce['ReservedInstances']:
if ReservedInstance['State'] == "active":
ValidPeriod = (((ReservedInstance['End'].astimezone(JST).date()) - now).days)
END = str((ReservedInstance['End']).astimezone(JST).date())
validcheck(RI, ReservedInstance['ReservedInstancesId'], ReservedInstance['InstanceType'], str(ReservedInstance['InstanceCount']), str(END), ValidPeriod)
def rds_reserved_instance_expiration_date_check():
RI="RDS"
client = boto3.client('rds')
response = client.describe_reserved_db_instances()
for ReservedDBInstance in response['ReservedDBInstances']:
if ReservedDBInstance['State'] == "active":
END = ((ReservedDBInstance['StartTime'].astimezone(JST) + timedelta(seconds=ReservedDBInstance['Duration'])).astimezone(JST).date())
ValidPeriod = (END - now).days
validcheck(RI, ReservedDBInstance['ReservedDBInstanceId'], ReservedDBInstance['DBInstanceClass'], str(ReservedDBInstance['DBInstanceCount']), str(END), ValidPeriod)
def elasticache_reserved_instance_expiration_date_check():
RI="ElastiCache"
client = boto3.client('elasticache')
response = client.describe_reserved_cache_nodes()
for ReservedCacheNode in response['ReservedCacheNodes']:
if ReservedCacheNode['State'] == "active":
END = ((ReservedCacheNode['StartTime'].astimezone(JST) + timedelta(seconds=ReservedCacheNode['Duration'])).astimezone(JST).date())
ValidPeriod = (END - now).days
validcheck(RI, ReservedCacheNode['ReservedCacheNodeId'], ReservedCacheNode['CacheNodeType'], "", str(END), ValidPeriod)
def es_reserved_instance_expiration_date_check():
RI="Elasticsearch"
client = boto3.client('es')
response = client.describe_reserved_elasticsearch_instances()
for ReservedElasticsearchInstance in response['ReservedElasticsearchInstances']:
if ReservedElasticsearchInstance['State'] == "active":
END = ((ReservedElasticsearchInstance['StartTime'].astimezone(JST) + timedelta(seconds=ReservedElasticsearchInstance['Duration'])).astimezone(JST).date())
ValidPeriod = (END - now).days
validcheck(RI, ReservedElasticsearchInstance['ReservedElasticsearchInstanceId'], ReservedElasticsearchInstance['ElasticsearchInstanceType'], "", str(END), ValidPeriod)
-
環境変数
- キー：AWS_ACCOUNT_ALIAS
値：AWSアカウント名 - キー：SLACK_WEBHOOK_URL
値：SlackのWebhook - キー：THRESHOLD10
値：10 - キー：THRESHOLD1
値：1
- キー：AWS_ACCOUNT_ALIAS
-
タイムアウト
- 1分
CloudWatch イベント ルール
-
スケジュール（注意：設定はGMT）
- Cron式：0 0 * * ? *
-
ターゲット
- Lambda関数：reserved_instances_check
-
ルール名
- reserved_instances_check
Slack通知例
更新時の注意点（AWSから届いたメールの内容）
現在お使いのリザーブドインスタンスを引き続きご利用いただく場合
- 現在お使いのリザーブドインスタンスと同じスペックで、来月以降もご使用する場合は、 同じリザーブドインスタンスを新規でご購入いただく形となります。
- 一度ご購入いただいたリザーブドインスタンスはキャンセルできませんのでご注意ください。
- 新規購入分も購入日より1年または3年の有効期限となります。
- 現在の有効期限が切れる直前に新規購入いただくことでリザーブドインスタンスの重複期間を最小限に抑えていただけます。
- 軽度・中度のリザーブドインスタンスをお使いの方は、現在提供しているタイプの中に同じ課金体系のものはありませんので、新規購入はできません。ご注意ください。