Minor bug fixes for common consumer and updated AWS plugin code with access credentials
[osm/MON.git] / osm_mon / plugins / CloudWatch / plugin_alarm.py
1 ##
2 # Copyright 2017 xFlow Research Pvt. Ltd
3 # This file is part of MON module
4 # All Rights Reserved.
5 #
6 # Licensed under the Apache License, Version 2.0 (the "License"); you may
7 # not use this file except in compliance with the License. You may obtain
8 # a copy of the License at
9 #
10 # http://www.apache.org/licenses/LICENSE-2.0
11 #
12 # Unless required by applicable law or agreed to in writing, software
13 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
14 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
15 # License for the specific language governing permissions and limitations
16 # under the License.
17 #
18 # For those usages not covered by the Apache License, Version 2.0 please
19 # contact with: wajeeha.hamid@xflowresearch.com
20 ##
21
22 '''
23 AWS-Plugin implements all the methods of MON to interact with AWS using the BOTO client
24 '''
25
26 __author__ = "Wajeeha Hamid"
27 __date__ = "18-September-2017"
28
29 import sys
30 import json
31 import logging as log
32 from jsmin import jsmin
33 from connection import Connection
34 from metric_alarms import MetricAlarm
35 from metrics import Metrics
36 sys.path.append("../../core/message_bus")
37 from producer import KafkaProducer
38
39 class plugin_alarms():
40 """Receives Alarm info from MetricAlarm and connects with the consumer/producer"""
41 def __init__ (self):
42 self.metricAlarm = MetricAlarm()
43 self.metric = Metrics()
44 self.producer = KafkaProducer('')
45 #---------------------------------------------------------------------------------------------------------------------------
46 def configure_alarm(self,alarm_info):
47 alarm_id = self.metricAlarm.config_alarm(self.cloudwatch_conn,alarm_info)
48 return alarm_id
49 #---------------------------------------------------------------------------------------------------------------------------
50 def update_alarm_configuration(self,test):
51 alarm_id = self.metricAlarm.update_alarm(self.cloudwatch_conn,test)
52 return alarm_id
53 #---------------------------------------------------------------------------------------------------------------------------
54 def delete_alarm(self,alarm_id):
55 return self.metricAlarm.delete_Alarm(self.cloudwatch_conn,alarm_id)
56 #---------------------------------------------------------------------------------------------------------------------------
57 def get_alarms_list(self,instance_id):
58 return self.metricAlarm.alarms_list(self.cloudwatch_conn,instance_id)
59 #---------------------------------------------------------------------------------------------------------------------------
60 def get_ack_details(self,ack_info):
61 return self.metricAlarm.alarm_details(self.cloudwatch_conn,ack_info)
62 #---------------------------------------------------------------------------------------------------------------------------
63 def get_metrics_data(self,metric_name,period,instance_id):
64 return self.metric.metricsData(self.cloudwatch_conn,metric_name,period,instance_id)
65 #---------------------------------------------------------------------------------------------------------------------------
66
67 def alarm_calls(self,message,aws_conn):
68 """Gets the message from the common consumer"""
69 try:
70 self.cloudwatch_conn = aws_conn['cloudwatch_connection']
71 self.ec2_conn = aws_conn['ec2_connection']
72
73 log.info("Action required against: %s" % (message.topic))
74 alarm_info = json.loads(message.value)
75
76 if message.key == "create_alarm_request":
77 alarm_inner_dict = alarm_info['alarm_create_request']
78 metric_status = self.check_metric(alarm_inner_dict['metric_name'])
79
80 if self.check_resource(alarm_inner_dict['resource_uuid']) == True and metric_status['status'] == True:
81 log.debug ("Resource and Metrics exists")
82
83 alarm_info['alarm_create_request']['metric_name'] = metric_status['metric_name']
84 #Generate a valid response message, send via producer
85 config_resp = self.configure_alarm(alarm_info) #alarm_info = message.value
86
87 if config_resp == None:
88 log.debug("Alarm Already exists")
89 payload = json.dumps(config_resp)
90 file = open('../../core/models/create_alarm_resp.json','wb').write((payload))
91 self.producer.create_alarm_response(key='create_alarm_response',message=payload,topic = 'alarm_response')
92
93 else:
94 payload = json.dumps(config_resp)
95 file = open('../../core/models/create_alarm_resp.json','wb').write((payload))
96 self.producer.create_alarm_response(key='create_alarm_response',message=payload,topic = 'alarm_response')
97 log.info("New alarm created with alarm info: %s", config_resp)
98
99 else:
100 log.error("Resource ID doesn't exists")
101
102 elif message.key == "acknowledge_alarm":
103 alarm_inner_dict = alarm_info['ack_details']
104
105 if self.check_resource(alarm_inner_dict['resource_uuid']) == True:
106 alarm_info = json.loads(message.value)
107 #Generate a valid response message, send via producer
108 ack_details = self.get_ack_details(alarm_info)
109 payload = json.dumps(ack_details)
110 file = open('../../core/models/notify_alarm.json','wb').write((payload))
111 self.producer.notify_alarm(key='notify_alarm',message=payload,topic = 'alarm_response')
112 log.info("Acknowledge sent: %s", ack_details)
113
114 else:
115 log.error("Resource ID is Incorrect")
116
117
118 elif message.key == "update_alarm_request":
119 alarm_inner_dict = alarm_info['alarm_update_request']
120 metric_status = self.check_metric(alarm_inner_dict['metric_name'])
121
122 if metric_status['status'] == True:
123 log.debug ("Resource and Metrics exists")
124 alarm_info['alarm_update_request']['metric_name'] = metric_status['metric_name']
125 #Generate a valid response message, send via producer
126 update_resp = self.update_alarm_configuration(alarm_info)
127
128 if update_resp == None:
129 payload = json.dumps(update_resp)
130 file = open('../../core/models/update_alarm_resp.json','wb').write((payload))
131 self.producer.update_alarm_response(key='update_alarm_response',message=payload,topic = 'alarm_response')
132 log.debug("Alarm Already exists")
133
134 else:
135 payload = json.dumps(update_resp)
136 file = open('../../core/models/update_alarm_resp.json','wb').write((payload))
137 self.producer.update_alarm_response(key='update_alarm_response',message=payload,topic = 'alarm_response')
138 log.info("Alarm Updated with alarm info: %s", update_resp)
139
140 else:
141 log.info ("Metric Not Supported")
142
143
144 elif message.key == "delete_alarm_request":
145 del_info = json.loads(message.value)
146 #Generate a valid response message, send via producer
147 del_resp = self.delete_alarm(del_info)
148 payload = json.dumps(del_resp)
149 file = open('../../core/models/delete_alarm_resp.json','wb').write((payload))
150 self.producer.delete_alarm_response(key='delete_alarm_response',message=payload,topic = 'alarm_response')
151 log.info("Alarm Deleted with alarm info: %s", del_resp)
152
153
154 elif message.key == "alarm_list_request":
155 alarm_inner_dict = alarm_info['alarm_list_request']
156
157 if self.check_resource(alarm_inner_dict['resource_uuid']) == True or alarm_inner_dict['resource_uuid'] == "":
158 #Generate a valid response message, send via producer
159 list_resp = self.get_alarms_list(alarm_info)#['alarm_names']
160 payload = json.dumps(list_resp)
161 file = open('../../core/models/list_alarm_resp.json','wb').write((payload))
162 self.producer.list_alarm_response(key='list_alarm_response',message=payload,topic = 'alarm_response')
163
164 else:
165 log.error("Resource ID is Incorrect")
166
167 else:
168 log.debug("Unknown key, no action will be performed")
169
170 except Exception as e:
171 log.error("Message retrieval exception: %s", str(e))
172 #---------------------------------------------------------------------------------------------------------------------------
173 def check_resource(self,resource_uuid):
174 '''Finding Resource with the resource_uuid'''
175 try:
176 check_resp = dict()
177 instances = self.ec2_conn.get_all_instance_status()
178
179 #resource_id
180 for instance_id in instances:
181 instance_id = str(instance_id).split(':')[1]
182
183 if instance_id == resource_uuid:
184 check_resp['resource_uuid'] = resource_uuid
185 return True
186 return False
187
188 except Exception as e:
189 log.error("Error in Plugin Inputs %s",str(e))
190 #---------------------------------------------------------------------------------------------------------------------------
191 def check_metric(self,metric_name):
192 ''' Checking whether the metric is supported by AWS '''
193 try:
194 check_resp = dict()
195
196 #metric_name
197 if metric_name == 'CPU_UTILIZATION':
198 metric_name = 'CPUUtilization'
199 metric_status = True
200
201 elif metric_name == 'DISK_READ_OPS':
202 metric_name = 'DiskReadOps'
203 metric_status = True
204
205 elif metric_name == 'DISK_WRITE_OPS':
206 metric_name = 'DiskWriteOps'
207 metric_status = True
208
209 elif metric_name == 'DISK_READ_BYTES':
210 metric_name = 'DiskReadBytes'
211 metric_status = True
212
213 elif metric_name == 'DISK_WRITE_BYTES':
214 metric_name = 'DiskWriteBytes'
215 metric_status = True
216
217 elif metric_name == 'PACKETS_RECEIVED':
218 metric_name = 'NetworkPacketsIn'
219 metric_status = True
220
221 elif metric_name == 'PACKETS_SENT':
222 metric_name = 'NetworkPacketsOut'
223 metric_status = True
224
225 else:
226 metric_name = None
227 metric_status = False
228 check_resp['metric_name'] = metric_name
229 #status
230
231 if metric_status == True:
232 check_resp['status'] = True
233 return check_resp
234
235 except Exception as e:
236 log.error("Error in Plugin Inputs %s",str(e))
237 #---------------------------------------------------------------------------------------------------------------------------