import logging
from typing import Dict, List
-import peewee
import yaml
-
from kafka import KafkaConsumer
-from osm_policy_module.core.config import Config
-from osm_policy_module.common.lcm_client import LcmClient
-
from osm_policy_module.common.alarm_config import AlarmConfig
+from osm_policy_module.common.lcm_client import LcmClient
from osm_policy_module.common.mon_client import MonClient
+from osm_policy_module.core.config import Config
from osm_policy_module.core.database import ScalingRecord, ScalingAlarm
log = logging.getLogger(__name__)
log.info("Sending scaling action message for ns: %s", alarm_id)
lcm_client.scale(alarm.scaling_record.nsr_id, alarm.scaling_record.name, alarm.action)
except ScalingAlarm.DoesNotExist:
- log.info("There is no action configured for alarm %.", alarm_id)
+ log.info("There is no action configured for alarm %s.", alarm_id)
except Exception:
log.exception("Error consuming message: ")