Lambda
1 import boto3
2 import datetime
3
4 client = boto3.client('ec2', )
5 alias = boto3.client('iam').list_account_aliases()['AccountAliases'][0]
6 regions = [region['RegionName'] for region in client.describe_regions()['Regions']]
7
8
9 def get_ri(regions, file):
10 global alias
11 with open(file, 'w', encoding='utf-8') as f:
12
13 for region in regions:
14 print(region)
15 ec2 = boto3.client('ec2', region_name=region,)
16 reserved_instances = ec2.describe_reserved_instances()
17 for reserved_instance in reserved_instances['ReservedInstances']:
18 state = reserved_instance['State']
19 endtimestr = str(reserved_instance['End']).split('+')[0]
20 endtime = datetime.datetime.strptime(endtimestr, '%Y-%m-%d %H:%M:%S')
21 timedif = (endtime - datetime.datetime.now()).days
22 if state == "active" and timedif <= 15:
23 msg = f'''
24 alias: {alias}
25 region: {region}
26 ReservedInstancesId: {reserved_instance['ReservedInstancesId']},
27 InstanceType: {reserved_instance['InstanceType']},
29 state: {reserved_instance['State']},
30 Start: {reserved_instance['Start']},
31 End: {reserved_instance['End']},
32 InstanceCount: {reserved_instance['InstanceCount']}
33 '''
34 f.write(msg)
35 print(msg)
36
37 def sends_sns(file):
38 client = boto3.client('sns', region_name='cn-northwest-1',
39 aws_access_key_id='AKIAQG4I2NOISOTWQG45',
40 aws_secret_access_key='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', )
41 try:
42 with open(file, 'r', encoding='utf-8') as f:
43 msg = f.read()
44 if msg:
45 response = client.publish(
46 TargetArn='arn:aws-cn:sns:cn-northwest-1:014782458769:UnitAlarm',
47 Message=msg,
48 )
49 except FileNotFoundError:
50 pass
51
52
53
54 def lambda_handler(event, context):
55 # TODO implement
56 file = '/tmp/ri_test.txt'
57 get_ri(regions, file)
58 sends_sns(file)
59
60
61 # if __name__ == '__main__':
62 # lambda_handler(event='txt', context='test')
邮件信息
