"""Carry out alarming requests via Aodh API."""
import json
-import logging as log
+import logging
+log = logging.getLogger(__name__)
from core.message_bus.producer import KafkaProducer
# Generate a valid response message, send via producer
try:
+ if alarm_status is True:
+ log.info("Alarm successfully created")
+
resp_message = self._response.generate_response(
'create_alarm_response', status=alarm_status,
alarm_id=alarm_id,
cor_id=alarm_details['correlation_id'])
+ log.info("Response Message: %s", resp_message)
self._producer.create_alarm_response(
'create_alarm_resonse', resp_message,
'alarm_response')
resp_message = self._response.generate_response(
'list_alarm_response', alarm_list=alarm_list,
cor_id=list_details['correlation_id'])
+ log.info("Response Message: %s", resp_message)
self._producer.list_alarm_response(
'list_alarm_response', resp_message,
'alarm_response')
'delete_alarm_response', alarm_id=alarm_id,
status=resp_status,
cor_id=request_details['correlation_id'])
+ log.info("Response message: %s", resp_message)
self._producer.delete_alarm_response(
'delete_alarm_response', resp_message,
'alarm_response')
'update_alarm_response', alarm_id=alarm_id,
cor_id=alarm_details['correlation_id'],
status=status)
+ log.info("Response message: %s", resp_message)
self._producer.update_alarm_response(
'update_alarm_response', resp_message,
'alarm_response')
result = self._common._perform_request(
url, auth_token, req_type="delete")
if str(result.status_code) == "404":
+ log.info("Alarm doesn't exist: %s", result.status_code)
# If status code is 404 alarm did not exist
return False
else: